ストリーム<Object>〜入力ストリーム

Question

タイプ Stream<Object>をInputStreamに変換するにはどうすればよいですか？現在、私はInputStreamの先のByteArrayに変換し、それを追加するデータのすべてを反復子とループを得る：

ByteArrayOutputStream bos = new ByteArrayOutputStream(); 
ObjectOutputStream oos = new ObjectOutputStream(bos); 

Iterator<MyType> myItr = MyObject.getStream().iterator(); 

while (myItr.hasNext()) { 

     oos.writeObject(myItr.next().toString() 
     .getBytes(StandardCharsets.UTF_8)); 
    } 
    oos.flush(); 
    oos.close(); 

    InputStream is = new ByteArrayInputStream(bao.toByteArray()); 

しかしこれを行うためのオーバーヘッドは何ですか？ストリームにテラバイトのデータが含まれている場合は、テラバイトのデータをメモリに吸い込まないでください。これを達成するためのより良い方法はありますか？

Answer 1

あなたはパイプを使用してInputStreamへOutputStreamを変換することができるはずです。

this answerに触発

PipedOutputStream pos = new PipedOutputStream(); 
InputStream is = new PipedInputStream(pos); 

new Thread(() -> { 
    try (ObjectOutputStream oos = new ObjectOutputStream(pos)) { 
     Iterator<MyType> myItr = MyObject.getStream().iterator(); 
     while (myItr.hasNext()) { 
      oos.writeObject(myItr.next().toString() 
       .getBytes(StandardCharsets.UTF_8)); 
     } 
    } catch (IOException e) { 
     // handle closed pipe etc. 
    } 
}).start(); 

。

Answer 2

これはあなたのために働くでしょうか？

https://gist.github.com/stephenhand/292cdd8bba7a452d83c51c00d9ef113c

これは、入力データとしてStream<byte[]>を取るInputStream実装です。バイト配列への任意のオブジェクトを.map()する必要がありますが、各オブジェクトをバイトとして表現する必要があります。

はそれだけで、消費者がInputStreamのより読み込むので、それは