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

Field Summary

Fields

Modifier and Type	Field	Description
static FlowMonitorState$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
FlowMonitorState$()

Method Summary

Modifier and Type	Method	Description
<U> FlowMonitorState.StreamState<U>	failed(java.lang.Throwable cause)
<U> FlowMonitorState.StreamState<U>	finished()
<U> FlowMonitorState.StreamState<U>	initialized()
<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

Field Detail

MODULE$

public static final FlowMonitorState$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

FlowMonitorState$

public FlowMonitorState$()

Method Detail

initialized

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

received

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

failed

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

finished

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