Class BehaviorProcessor.BehaviorSubscription<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.processors.BehaviorProcessor.BehaviorSubscription<T>
All Implemented Interfaces:
Predicate<Object>, AppendOnlyLinkedArrayList.NonThrowingPredicate<Object>, Serializable, org.reactivestreams.Subscription
Enclosing class:
BehaviorProcessor<T>

static final class BehaviorProcessor.BehaviorSubscription<@NonNull T> extends AtomicLong implements org.reactivestreams.Subscription, AppendOnlyLinkedArrayList.NonThrowingPredicate<Object>
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

      final org.reactivestreams.Subscriber<? super T> downstream
    • state

      final BehaviorProcessor<T> state
    • next

      boolean next
    • emitting

      boolean emitting
    • queue

    • fastPath

      boolean fastPath
    • cancelled

      volatile boolean cancelled
    • index

      long index
  • Constructor Details

  • Method Details

    • request

      public void request(long n)
      Specified by:
      request in interface org.reactivestreams.Subscription
    • cancel

      public void cancel()
      Specified by:
      cancel in interface org.reactivestreams.Subscription
    • emitFirst

      void emitFirst()
    • emitNext

      void emitNext(Object value, long stateIndex)
    • test

      public boolean test(Object o)
      Description copied from interface: Predicate
      Test the given input value and return a boolean.
      Specified by:
      test in interface AppendOnlyLinkedArrayList.NonThrowingPredicate<T>
      Specified by:
      test in interface Predicate<T>
      Parameters:
      o - the value
      Returns:
      the boolean result
    • emitLoop

      void emitLoop()
    • isFull

      public boolean isFull()