public interface FlowMonitor<T>
FlowMonitorState.StreamState<T>
state()
FlowMonitorState.StreamState<T> state()