Package com.influxdb.client.internal.flowable

Class BackpressureBatchesBufferStrategy

java.lang.Object

com.influxdb.client.internal.flowable.BackpressureBatchesBufferStrategy

All Implemented Interfaces:

io.reactivex.rxjava3.core.FlowableOperator<AbstractWriteClient.BatchWriteItem,AbstractWriteClient.BatchWriteItem>

public final class BackpressureBatchesBufferStrategy
extends Object
implements io.reactivex.rxjava3.core.FlowableOperator<AbstractWriteClient.BatchWriteItem,AbstractWriteClient.BatchWriteItem>

The backpressure strategy which uses total sum of AbstractWriteClient.BatchWriteItem.length() to determine backpressure boundary.

The original strategy FlowableOnBackpressureBufferStrategy uses only count of elements.

See Also:

• FlowableOnBackpressureBufferStrategy

Constructor Summary

Constructors

Constructor	Description
BackpressureBatchesBufferStrategy(long bufferSize, io.reactivex.rxjava3.functions.Action onOverflow, io.reactivex.rxjava3.core.BackpressureOverflowStrategy strategy)

Method Summary

Modifier and Type	Method	Description
@NonNull org.reactivestreams.Subscriber<? super AbstractWriteClient.BatchWriteItem>	apply(@NonNull org.reactivestreams.Subscriber<? super AbstractWriteClient.BatchWriteItem> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BackpressureBatchesBufferStrategy

public BackpressureBatchesBufferStrategy(long bufferSize,
 io.reactivex.rxjava3.functions.Action onOverflow,
 io.reactivex.rxjava3.core.BackpressureOverflowStrategy strategy)

Method Details

apply

@NonNull
public @NonNull org.reactivestreams.Subscriber<? super AbstractWriteClient.BatchWriteItem> apply(@NonNull
 @NonNull org.reactivestreams.Subscriber<? super AbstractWriteClient.BatchWriteItem> subscriber)
                                                                                          throws Throwable

Specified by:

apply in interface io.reactivex.rxjava3.core.FlowableOperator<AbstractWriteClient.BatchWriteItem,AbstractWriteClient.BatchWriteItem>

Throws:

Throwable