akka.stream

Class FlowMonitorState

java.lang.Object

akka.stream.FlowMonitorState

public class FlowMonitorState
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlowMonitorState.Failed Stream failed
static class	FlowMonitorState.Failed$
static class	FlowMonitorState.Finished$ Stream completed successfully
static class	FlowMonitorState.Initialized$ Stream was created, but no events have passed through it
static class	FlowMonitorState.Received<U> Stream processed a message
static class	FlowMonitorState.Received$
static interface	FlowMonitorState.StreamState<U>

Constructor Summary

Constructors

Constructor and Description
FlowMonitorState()

Method Summary

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

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()

Java API

Returns:

(undocumented)

received

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

Java API

Parameters:

msg - (undocumented)

Returns:

(undocumented)

failed

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

Java API

Parameters:

cause - (undocumented)

Returns:

(undocumented)

finished

public static <U> FlowMonitorState.Finished$ finished()

Java API

Returns:

(undocumented)