public abstract class StreamUtils extends Object
|Modifier and Type||Method and Description|
Convert the given
public static <M> Stream<M> asStream(BlockingStream<M> messageStream)
messageStreamto a regular java
Stream. Note that the returned stream will block during iteration if the end of the stream is reached so take heed of this in production code. Closing this
Streamwill close the underling
Copyright © 2010–2020. All rights reserved.