Package org.axonframework.common.stream

Class StreamUtils

java.lang.Object

org.axonframework.common.stream.StreamUtils

public abstract class StreamUtils
extends Object

Utility class for working with Streams.

Method Summary

Modifier and Type	Method	Description
static <M> Stream<M>	asStream(BlockingStream<M> messageStream)	Convert the given messageStream to a regular java Stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

asStream

public static <M> Stream<M> asStream(BlockingStream<M> messageStream)

Convert the given messageStream to 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 Stream will close the underling messageStream as well.

Type Parameters:

M - The type of entry contained in the stream

Parameters:

messageStream - the input TrackingEventStream

Returns:

the output Stream after conversion