Package org.apache.pekko.stream

Class FlowMonitorState$

java.lang.Object

org.apache.pekko.stream.FlowMonitorState$

public class FlowMonitorState$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final 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(Throwable cause)	Java API
<U> FlowMonitorState.StreamState<U>	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 Details

MODULE$

public static final FlowMonitorState$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

FlowMonitorState$

public FlowMonitorState$()

Method Details

initialized

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

Java API

received

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

Java API

failed

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

Java API

finished

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

Java API