Top Description Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.parallel

public final Class ParallelCollect<T, C>

extends ParallelFlowable<C>
Class Inheritance
Type Parameters
<T>
the input value type
<C>
the collection type
Imports
org.reactivestreams.*, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.*, io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber, io.reactivex.rxjava3.internal.subscriptions.*, io.reactivex.rxjava3.parallel.ParallelFlowable, io.reactivex.rxjava3.plugins.RxJavaPlugins, java.util.Objects
Reduce the sequence of values in each 'rail' to a single value.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ParallelCollect.ParallelCollectSubscriber<T, C>

Field Summary

Modifier and TypeField and Description
pack-priv final BiConsumer<? super C, ? super T>
collector

pack-priv final Supplier<? extends C>
initialCollection

pack-priv final ParallelFlowable<? extends T>
source

Constructor Summary

AccessConstructor and Description
public
ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C, ? super T> collector)

Method Summary

Modifier and TypeMethod and Description
public int
parallelism()

Implements abstract io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Returns the number of expected parallel Subscribers.
pack-priv void
reportError(Subscriber<?>[] subscribers, Throwable ex)

public void
subscribe(Subscriber<? super C>[] subscribers)

Inherited from io.reactivex.rxjava3.parallel.ParallelFlowable:
collectcollectcomposeconcatMapconcatMapconcatMapDelayErrorconcatMapDelayErrordoAfterNextdoAfterTerminateddoOnCanceldoOnCompletedoOnErrordoOnNextdoOnNextdoOnNextdoOnRequestdoOnSubscribefilterfilterfilterflatMapflatMapflatMapflatMapflatMapIterableflatMapIterableflatMapStreamflatMapStreamfromfromfromfromArraymapmapmapmapOptionalmapOptionalmapOptionalreducereducerunOnrunOnsequentialsequentialsequentialDelayErrorsequentialDelayErrorsortedsortedsubscribetotoSortedListtoSortedListvalidate

Field Detail

collectorback to summary
pack-priv final BiConsumer<? super C, ? super T> collector
initialCollectionback to summary
pack-priv final Supplier<? extends C> initialCollection
sourceback to summary
pack-priv final ParallelFlowable<? extends T> source

Constructor Detail

ParallelCollectback to summary
public ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C, ? super T> collector)

Method Detail

parallelismback to summary
public int parallelism()

Implements abstract io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Doc from io.reactivex.rxjava3.parallel.ParallelFlowable.parallelism.

Returns the number of expected parallel Subscribers.

Returns:int

the number of expected parallel Subscribers

Annotations
@Override
reportErrorback to summary
pack-priv void reportError(Subscriber<?>[] subscribers, Throwable ex)
subscribeback to summary
public void subscribe(Subscriber<? super C>[] subscribers)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.parallel back to summary

pack-priv final Class ParallelCollect.ParallelCollectSubscriber<T, C>

extends DeferredScalarSubscriber<T, C>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv C
collection

pack-priv final BiConsumer<? super C, ? super T>
collector

pack-priv boolean
done

private static final long
serialVersionUID

Hides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.serialVersionUID.

Inherited from io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber:
hasValueupstream

Constructor Summary

AccessConstructor and Description
pack-priv
ParallelCollectSubscriber(Subscriber<? super C> subscriber, C initialValue, BiConsumer<? super C, ? super T> collector)

Method Summary

Modifier and TypeMethod and Description
public void
cancel()

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.cancel.

Implements org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.
public void
onComplete()

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onComplete.

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public void
onError(Throwable
the throwable signaled
t)

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onError.

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.
public void
onNext(T
the element signaled
t)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
public void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
s)

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onSubscribe.

Implements org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

Field Detail

collectionback to summary
pack-priv C collection
collectorback to summary
pack-priv final BiConsumer<? super C, ? super T> collector
doneback to summary
pack-priv boolean done
serialVersionUIDback to summary
private static final long serialVersionUID

Hides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.serialVersionUID.

Constructor Detail

ParallelCollectSubscriberback to summary
pack-priv ParallelCollectSubscriber(Subscriber<? super C> subscriber, C initialValue, BiConsumer<? super C, ? super T> collector)

Method Detail

cancelback to summary
public void cancel()

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.cancel.

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations
@Override
onCompleteback to summary
public void onComplete()

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onComplete.

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations
@Override
onErrorback to summary
public void onError(Throwable t)

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onError.

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters
t:Throwable

the throwable signaled

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
t:T

the element signaled

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Subscription s)

Overrides io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber.onSubscribe.

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters
s:Subscription

the Subscription that allows requesting data via Subscription#request(long)

Annotations
@Override