Class SinkRefStageImpl<In>

  • All Implemented Interfaces:

    public final class SinkRefStageImpl<In>
    extends GraphStageWithMaterializedValue<SinkShape<In>,​scala.concurrent.Future<SourceRef<In>>>
    INTERNAL API: Actual operator implementation backing SinkRefs.

    If initialPartnerRef is set, then the remote side is already set up. If it is none, then we are the side creating the ref.

    • Constructor Detail

      • SinkRefStageImpl

        public SinkRefStageImpl​(OptionVal<ActorRef> initialPartnerRef)
    • Method Detail

      • shape

        public SinkShape<In> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object