org.axonframework.messaging

Class StreamUtils

java.lang.Object

org.axonframework.messaging.StreamUtils

public abstract class StreamUtils
extends Object

Utility class for working with Streams.

Method Summary

Modifier and Type	Method and Description
static <M extends Message<?>> Stream<M>	asStream(MessageStream<M> messageStream) Convert the given messageStream to a regular java Stream of messages.

Methods inherited from class java.lang.Object

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

Method Detail

asStream

public static <M extends Message<?>> Stream<M> asStream(MessageStream<M> messageStream)

Convert the given 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.

Parameters:

messageStream - the input TrackingEventStream

Returns:

the output Stream after conversion