rx

Class BackpressureOverflow

java.lang.Object

rx.BackpressureOverflow

@Experimental
public final class BackpressureOverflow
extends Object

Generic strategy and default implementations to deal with backpressure buffer overflows.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BackpressureOverflow.Strategy Represents a callback called when a value is about to be dropped due to lack of downstream requests.

Field Summary

Fields

Modifier and Type	Field and Description
static BackpressureOverflow.Strategy	ON_OVERFLOW_DEFAULT By default, signal a MissingBackressureException due to lack of requests.
static BackpressureOverflow.Strategy	ON_OVERFLOW_DROP_LATEST Drop the latest value.
static BackpressureOverflow.Strategy	ON_OVERFLOW_DROP_OLDEST Drop the oldest value in the buffer.
static BackpressureOverflow.Strategy	ON_OVERFLOW_ERROR Signal a MissingBackressureException due to lack of requests.

Constructor Summary

Constructors

Constructor and Description
BackpressureOverflow()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

ON_OVERFLOW_ERROR

public static final BackpressureOverflow.Strategy ON_OVERFLOW_ERROR

Signal a MissingBackressureException due to lack of requests.

ON_OVERFLOW_DEFAULT

public static final BackpressureOverflow.Strategy ON_OVERFLOW_DEFAULT

By default, signal a MissingBackressureException due to lack of requests.

ON_OVERFLOW_DROP_OLDEST

public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_OLDEST

Drop the oldest value in the buffer.

ON_OVERFLOW_DROP_LATEST

public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_LATEST

Drop the latest value.

Constructor Detail

BackpressureOverflow

public BackpressureOverflow()