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>>