Interface DemandAware.Sink

  • Enclosing interface:
    DemandAware

    public static interface DemandAware.Sink
    A demand-aware DemandAware.Sink that accepts data. It can signal its DemandAware.Source demand/readiness to emit more data. Instances of implementing classes are required to be thread-safe as they are shared amongst multiple threads.