Class FlowableDistinct.DistinctSubscriber<T,K>

java.lang.Object
io.reactivex.rxjava3.internal.subscribers.BasicFuseableSubscriber<T,T>
io.reactivex.rxjava3.internal.operators.flowable.FlowableDistinct.DistinctSubscriber<T,K>
All Implemented Interfaces:
FlowableSubscriber<T>, QueueFuseable<T>, QueueSubscription<T>, SimpleQueue<T>, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription
Enclosing class:
FlowableDistinct<T,K>

static final class FlowableDistinct.DistinctSubscriber<T,K> extends BasicFuseableSubscriber<T,T>
  • Field Details

    • collection

      final Collection<? super K> collection
    • keySelector

      final Function<? super T,K> keySelector
  • Constructor Details

    • DistinctSubscriber

      DistinctSubscriber(org.reactivestreams.Subscriber<? super T> actual, Function<? super T,K> keySelector, Collection<? super K> collection)
  • Method Details