Scala: InputStream to Array [Byte]

Con Scala, ¿cuál es la mejor manera de leer desde un InputStream a un bytearray?Scala: InputStream to Array [Byte]

puedo ver que se puede convertir un InputStream a char matriz

Source.fromInputStream(is).toArray()

Fuente

2011-02-05 rahul

¿Qué tal:

Stream.continually(is.read).takeWhile(_ != -1).map(_.toByte).toArray

Fuente

2011-02-05 07:58:38 Eastsun

¿Podría explicar la diferencia entre esto y la variante en la pregunta? – Jus12

@ Jus12 Estaba buscando una matriz de bytes. Lo que tengo en la pregunta, es una forma de obtener la matriz de caracteres. – rahul

+11

¿No creará eso una gran lista vinculada y luego la convertirá en una matriz? Eso no parece muy eficiente, en tiempo o memoria. –

def inputStreamToByteArray(is: InputStream): Array[Byte] = { 
    val buf = ListBuffer[Byte]() 
    var b = is.read() 
    while (b != -1) { 
     buf.append(b.byteValue) 
     b = is.read() 
    } 
    buf.toArray 
}

Fuente

2011-02-05 06:43:59

¿Lista [Byte] tiene un método "agregar"? – Eastsun

Buena pregunta. Acabo de editarlo para usar un ListBuffer mutable –

import scala.tools.nsc.io.Streamable 
Streamable.bytes(is)

No recuerdo cómo reciente que es: probablemente mide en días. Volviendo a 2,8, que es más como

new Streamable.Bytes { def inputStream() = is } toByteArray

Fuente

2011-02-05 07:07:16 extempore

¿Es seguro usar cosas de los paquetes scala.tools? ¿Son parte de la biblioteca estándar? –

No. Pero si quieres saber cómo escribirlo, ahí está. – extempore

Parece que se ha movido al paquete 'scala.reflect.io' más estándar ahora. – Thilo

En una línea similar a la respuesta de Eastsun ... Empecé esto como un comentario, pero terminó siendo sólo un poco a largo!

Te advierto contra el uso de Stream, si mantiene una referencia al elemento principal, las transmisiones pueden consumir mucha memoria.

Teniendo en cuenta que usted sólo va a leer en el archivo una vez, luego Iterator es una opción mucho mejor:

def inputStreamToByteArray(is: InputStream): Array[Byte] = 
    Iterator continually is.read takeWhile (-1 !=) map (_.toByte) toArray

Fuente

2011-02-05 13:00:53

Con Scala IO, esto debería funcionar:

cuello de botella

def inputStreamToByteArray(is: InputStream): Array[Byte] = 
    Resource.fromInputStream(in).byteArray

Fuente

2011-03-02 20:21:53

Sólo eliminado en nuestro código de servidor al reemplazar

Stream.continually(request.getInputStream.read()).takeWhile(_ != -1).map(_.toByte).toArray

con

org.apache.commons.io.IOUtils.toByteArray(request.getInputStream)

Fuente

2013-01-18 16:11:55

Eso es org.apache.commons.io.IOUtils.toByteArray, en caso de que alguien se lo esté preguntando. – Haakon

@Haakon gracias! Actualicé la respuesta. –

Esto definitivamente se siente más rápido. ¿Alguien hizo benchmarks o pruebas con archivos más grandes? – EdgeCaseBerg

Source.fromInputStream (es) .map (. _ ToByte) .toArray

Fuente

2014-05-11 17:09:14 TimT

Esto falla en los archivos de texto con codificación binaria/falsa: http://stackoverflow.com/questions/13327536/malformedinputexception-when-trying-to-read-entire-file –

He aquí un método que utiliza scalaz-stream:

import scalaz.concurrent.Task 
import scalaz.stream._ 
import scodec.bits.ByteVector 

def allBytesR(is: InputStream): Process[Task, ByteVector] = 
    io.chunkR(is).evalMap(_(4096)).reduce(_ ++ _).lastOr(ByteVector.empty)

Fuente

2015-08-31 13:33:29

probablemente no haya ninguna razón para reducir, eso vencería la naturaleza incremental de streams – OlegYch

La razón es que la pregunta requiere una matriz de bytes. –

Con better-files, sólo tiene que hacer is.bytes

Fuente

2016-03-09 04:34:27 pathikrit

Scala: InputStream to Array [Byte]

Respuesta

Cuestiones relacionadas