akka.stream

Class FlowMonitorState$

java.lang.Object

akka.stream.FlowMonitorState$

public class FlowMonitorState$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
FlowMonitorState$()

Method Summary

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

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

Java API

Returns:

(undocumented)

received

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

Java API

Parameters:

msg - (undocumented)

Returns:

(undocumented)

failed

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

Java API

Parameters:

cause - (undocumented)

Returns:

(undocumented)

finished

public <U> FlowMonitorState.Finished$ finished()

Java API

Returns:

(undocumented)