akka.stream.impl.fusing

Interface SubSink.Command

All Known Implementing Classes:

SubSink.Cancel$, SubSink.RequestOne$

Enclosing class:

SubSink<T>

public static interface SubSink.Command

Steady state: sink has been materialized, commands can be delivered through the callback