Package akka.stream.impl

Class ProcessorModulePhase

  • All Implemented Interfaces:
    PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>
    public final class ProcessorModulePhase
extends java.lang.Object
implements PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>
    INTERNAL API

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void assignPort​(InPort in, int slot, org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)  
      void assignPort​(OutPort out, int slot, org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)  
      org.reactivestreams.Publisher<java.lang.Object> createPublisher​(OutPort out, org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)  
      scala.Tuple2<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>,​java.lang.Object> materializeAtomic​(StreamLayout.AtomicModule<Shape,​java.lang.Object> mod, Attributes attributes)  
      java.lang.String name()  
      void onIslandReady()  
      void takePublisher​(int slot, org.reactivestreams.Publisher<java.lang.Object> publisher)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ProcessorModulePhase

        public ProcessorModulePhase()

    • Method Detail

      • assignPort

        public void assignPort​(InPort in,
                       int slot,
                       org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)
        Specified by:
        assignPort in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • assignPort

        public void assignPort​(OutPort out,
                       int slot,
                       org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)
        Specified by:
        assignPort in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • createPublisher

        public org.reactivestreams.Publisher<java.lang.Object> createPublisher​(OutPort out,
                                                                       org.reactivestreams.Processor<java.lang.Object,​java.lang.Object> logic)
        Specified by:
        createPublisher in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • materializeAtomic

        public scala.Tuple2<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>,​java.lang.Object> materializeAtomic​(StreamLayout.AtomicModule<Shape,​java.lang.Object> mod,
                                                                                                                                     Attributes attributes)
        Specified by:
        materializeAtomic in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • name

        public java.lang.String name()
        Specified by:
        name in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • onIslandReady

        public void onIslandReady()
        Specified by:
        onIslandReady in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>

      • takePublisher

        public void takePublisher​(int slot,
                          org.reactivestreams.Publisher<java.lang.Object> publisher)
        Specified by:
        takePublisher in interface PhaseIsland<org.reactivestreams.Processor<java.lang.Object,​java.lang.Object>>