Creazione di un InputStream Java da un enumeratore [Array [Byte]]

Question

Ho letto molto su Iteratees & Enumeratori per implementare un nuovo modulo nella mia applicazione.

sono ora ad un punto in cui sto integrando con una libreria Java 3rd party, e sono bloccato a lavorare con questo metodo:

public Email addAttachment(String name, InputStream file) throws IOException { 
    this.attachments.put(name, file); 
    return this; 
} 

Quello che ho nel mio API è il corpo tornato da a WS Chiamata HTTP che è Enumerator[Array[Byte]].

Mi chiedo ora come scrivere un Iteratee che elabora i blocchi di Array[Bytes] e crei un InputStream da utilizzare con questo metodo.

(barra laterale): esistono altre versioni del metodo addAttachment che richiedono java.io.File tuttavia, in questa operazione, desidero evitare di scrivere sul disco e preferirei gestire gli stream.

ho cercato di iniziare scrivendo qualcosa di simile:

Iteratee.foreach[Array[Byte]] { bytes => 
    ??? 
} 

Tuttavia io non sono sicuro di come interagire con il java InputStream qui. Ho trovato qualcosa chiamato ByteArrayInputStream, ma che prende l'intero Array[Byte] nel suo costruttore, che non sono sicuro che funzionerebbe in questo scenario, visto che sto lavorando con chunk?

Probabilmente ho bisogno di un aiuto Java qui!

Grazie per qualsiasi aiuto in anticipo.

Answer 1

Se ti sto seguendo, penso che si desidera lavorare con PipedInputStream e PipedOutputStream:

https://docs.oracle.com/javase/8/docs/api/java/io/PipedInputStream.html

di utilizzarli sempre in coppia. È possibile costruire la coppia in questo modo:

PipedInputStream in = new PipedInputStream(); //can also specify a buffer size 
PipedOutputStream out = new PipedOutputSream(in); 

Passare il flusso di input per l'API, e nel proprio codice iterare attraverso i mandrini e scrivere il byte.

L'unica avvertenza è che è necessario leggere/scrivere in thread separati. Nel tuo caso, è probabilmente utile fare la tua iterazione/scrittura in un thread separato. Sono sicuro che si può gestire a Scala meglio di me, in Java sarebbe qualcosa di simile:

PipedInputStream in = new PipedInputStream(); //can also specify a buffer size 
PipedOutputStream out = new PipedOutputSream(out); 
new Thread(() -> { 
    // do your looping in here, write to 'out' 
    out.close(); 
}).run(); 
email.addAttachment(in); 
email.send(); 
in.close(); 

(Tralasciando gestione delle eccezioni & gestione delle risorse per chiarezza)