public abstract class StreamUtils extends Object
Modifier and Type | Method and Description |
---|---|
static <M extends Message<?>> |
asStream(MessageStream<M> messageStream)
Convert the given
messageStream to a regular java Stream of messages. |
public static <M extends Message<?>> Stream<M> asStream(MessageStream<M> messageStream)
messageStream
to a regular java Stream
of messages. 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.messageStream
- the input TrackingEventStream
Stream
after conversionCopyright © 2010–2017. All rights reserved.