Package akka.stream

Class FlowMonitorState

java.lang.Object

akka.stream.FlowMonitorState

public class FlowMonitorState
extends java.lang.Object

Stream was created, but no events have passed through it

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FlowMonitorState.Failed	Stream failed
static class	FlowMonitorState.Failed$
static class	FlowMonitorState.Finished$	Stream completed successfully
static class	FlowMonitorState.Initialized$
static class	FlowMonitorState.Received<U>	Stream processed a message
static class	FlowMonitorState.Received$
static interface	FlowMonitorState.StreamState<U>

Constructor Summary

Constructors

Constructor	Description
FlowMonitorState()

Method Summary

Modifier and Type	Method	Description
static <U> FlowMonitorState.StreamState<U>	failed(java.lang.Throwable cause)
static <U> FlowMonitorState.StreamState<U>	finished()
static <U> FlowMonitorState.StreamState<U>	initialized()
static <U> FlowMonitorState.StreamState<U>	received(U msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowMonitorState

public FlowMonitorState()

Method Detail

initialized

public static <U> FlowMonitorState.StreamState<U> initialized()

received

public static <U> FlowMonitorState.StreamState<U> received(U msg)

failed

public static <U> FlowMonitorState.StreamState<U> failed(java.lang.Throwable cause)

finished

public static <U> FlowMonitorState.StreamState<U> finished()