Class SinkModulePhase

  • All Implemented Interfaces:
    PhaseIsland<java.lang.Object>

    public final class SinkModulePhase
    extends java.lang.Object
    implements PhaseIsland<java.lang.Object>
    INTERNAL API
    • Method Detail

      • assignPort

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

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

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

        public java.lang.String name()
        Specified by:
        name in interface PhaseIsland<java.lang.Object>
      • subscriberOrVirtualPublisher

        public java.lang.Object subscriberOrVirtualPublisher()
      • subscriberOrVirtualPublisher_$eq

        public void subscriberOrVirtualPublisher_$eq​(java.lang.Object x$1)
      • takePublisher

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