Class PublisherSource<Out>

  • All Implemented Interfaces:
    Graph<SourceShape<Out>,​NotUsed>, StreamLayout.AtomicModule<SourceShape<Out>,​NotUsed>

    public final class PublisherSource<Out>
    extends SourceModule<Out,​NotUsed>
    INTERNAL API Construct a transformation starting with given publisher. The transformation steps are executed by a series of Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.