Preguntas etiquetadas con stream

187
Limitar una secuencia por un predicado

¿Existe una operación de flujo Java 8 que limite un (potencialmente infinito) Streamhasta que el primer elemento no coincida con un predicado? En Java 9 podemos usar takeWhilecomo en el ejemplo a continuación para imprimir todos los números menores que 10. IntStream .iterate(1, n -> n + 1)...

185
mmap () vs. bloques de lectura

Estoy trabajando en un programa que procesará archivos que podrían tener un tamaño de 100 GB o más. Los archivos contienen conjuntos de registros de longitud variable. Tengo una primera implementación en funcionamiento y ahora estoy buscando mejorar el rendimiento, particularmente para hacer E / S...

178
Agregar BigDecimals usando Streams

Tengo una colección de BigDecimals (en este ejemplo, a LinkedList) que me gustaría agregar. ¿Es posible usar transmisiones para esto? Noté que la Streamclase tiene varios métodos Stream::mapToInt Stream::mapToDouble Stream::mapToLong Cada uno de los cuales tiene un sum()método conveniente ....

175
Stream.Seek (0, SeekOrigin.Begin) o Position = 0

Cuando necesita restablecer una transmisión al comienzo (por ejemplo MemoryStream), es mejor usar stream.Seek(0, SeekOrigin.Begin); o stream.Position = 0; He visto que ambos funcionan bien, pero me preguntaba si uno era más correcto que el

166
¿Eliminar el lector de flujo cierra el flujo?

Estoy enviando una secuencia a métodos para escribir, y en esos métodos estoy usando un lector / wrtier binario. Cuando el lector / escritor se deshace, ya sea porusing o solo cuando no está referenciado, ¿también se cierra la secuencia? Enviaría un BinaryReader / Writer, pero también estoy usando...

164
Error al manejar con secuencias de node.js

¿Cuál es la forma correcta de manejar los errores con las transmisiones? Ya sé que hay un evento de "error" en el que puedes escuchar, pero quiero saber más detalles sobre situaciones arbitrariamente complicadas. Para empezar, ¿qué haces cuando quieres hacer una cadena de tubería...