Class OnSubscribeJoin.ResultSink

    • Field Detail

      • guard

        final java.lang.Object guard
      • leftDone

        boolean leftDone
        Guarded by guard.
      • leftId

        int leftId
        Guarded by guard.
      • leftMap

        final java.util.Map<java.lang.Integer,​TLeft> leftMap
        Guarded by guard.
      • rightDone

        boolean rightDone
        Guarded by guard.
      • rightId

        int rightId
        Guarded by guard.
      • rightMap

        final java.util.Map<java.lang.Integer,​TRight> rightMap
        Guarded by guard.
    • Constructor Detail

      • ResultSink

        public ResultSink​(Subscriber<? super R> subscriber)
    • Method Detail

      • run

        public void run()