Package org.apache.pekko.stream

Class FlowMonitorState

java.lang.Object

org.apache.pekko.stream.FlowMonitorState

public class FlowMonitorState
extends Object

Nested Class Summary

Nested Classes

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

FlowMonitorState

public FlowMonitorState()

Method Details

initialized

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

Java API

received

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

Java API

failed

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

Java API

finished

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

Java API