Class MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<R>
io.reactivex.rxjava3.internal.jdk8.MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
All Implemented Interfaces:
MaybeObserver<T>, SingleObserver<T>, QueueFuseable<R>, QueueSubscription<R>, SimpleQueue<R>, Serializable, org.reactivestreams.Subscription
Enclosing class:
MaybeFlattenStreamAsFlowable<T,R>

static final class MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R> extends BasicIntQueueSubscription<R> implements MaybeObserver<T>, SingleObserver<T>
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • downstream

      final org.reactivestreams.Subscriber<? super R> downstream
    • mapper

      final Function<? super T,? extends Stream<? extends R>> mapper
    • requested

      final AtomicLong requested
    • upstream

      Disposable upstream
    • iterator

      volatile Iterator<? extends R> iterator
    • close

    • once

      boolean once
    • cancelled

      volatile boolean cancelled
    • outputFused

      boolean outputFused
    • emitted

      long emitted
  • Constructor Details

    • FlattenStreamMultiObserver

      FlattenStreamMultiObserver(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends Stream<? extends R>> mapper)
  • Method Details