ストリームはすでに稼働中または閉鎖中です。サプライヤがサポートしていません

Question

私はJava 8ストリームコーディングを初めて使用しています。 ここにコードがあります。私は走ろうとしています。あなたが業者を使用する場合は

Supplier filteredSupplier =() -> Stream.of(filteredStream.toArray(Obj[]::new)); 
Stream.concat((Stream<Obj>)filteredSupplier.get(), Stream.of(objs)).forEach(some operation); 

は、私の知る限りでは、あなたはサプライヤーでget（）FUNCを使用してストリームにあなたが望む任意の時間を使用することができます。それでも、私は、 "ストリームはすでに操作されているか、またはを閉じています"となっています。

私の理解を助けてください、サプライヤーを経由してくるストリームを使用することについての制限はありますか？

Answer 1

この行に

Supplier filteredSupplier =() -> Stream.of(filteredStream.toArray(Obj[]::new)); 

二つの流れがある：filteredStreamとStream.of(...)によって返さ一つ。

getメソッドを呼び出してSupplierを呼び出すと、Stream.of(...)が呼び出され、新しいストリームが作成されます。ただし、それぞれのコールは同じfilteredStreamを使用します。最初の呼び出しでfilteredStreamストリームが「使い切った」ため、Supplierは2度目の呼び出しでは機能しません。

が例外を回避するには、以下のようなもので、上記の行を交換してください：

Obj[] array = filteredStream.toArray(Obj[]::new); 
    Supplier<Stream<Obj>> filteredSupplier =() -> Stream.of(array); 

これは関係なく、あなたがSupplierのgetメソッド呼び出し回数を、一度だけfilteredStreamを使用しません。