Package org.apache.pekko.stream
Interface FlowMonitor<T>
- Type Parameters:
T- Type of messages passed by the stream
public interface FlowMonitor<T>
Used to monitor the state of a stream
-
Method Summary
-
Method Details
-
state
FlowMonitorState.StreamState<T> state()
-