public final enum

BackpressureStrategy

extends Enum<E extends Enum<E>>
java.lang.Object
   ↳ java.lang.Enum<E extends java.lang.Enum<E>>
     ↳ io.reactivex.BackpressureStrategy

Class Overview

Represents the options for applying backpressure to a source sequence.

Summary

Enum Values
BackpressureStrategy  BUFFER  Buffers all onNext values until the downstream consumes it. 
BackpressureStrategy  DROP  Drops the most recent onNext value if the downstream can't keep up. 
BackpressureStrategy  ERROR  Signals a MissingBackpressureException in case the downstream can't keep up. 
BackpressureStrategy  LATEST  Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up. 
BackpressureStrategy  MISSING  OnNext events are written without any buffering or dropping. 
Public Methods
static BackpressureStrategy valueOf(String name)
final static BackpressureStrategy[] values()
[Expand]
Inherited Methods
From class java.lang.Enum
From class java.lang.Object
From interface java.lang.Comparable

Enum Values

public static final BackpressureStrategy BUFFER

Buffers all onNext values until the downstream consumes it.

public static final BackpressureStrategy DROP

Drops the most recent onNext value if the downstream can't keep up.

public static final BackpressureStrategy ERROR

Signals a MissingBackpressureException in case the downstream can't keep up.

public static final BackpressureStrategy LATEST

Keeps only the latest onNext value, overwriting any previous value if the downstream can't keep up.

public static final BackpressureStrategy MISSING

OnNext events are written without any buffering or dropping. Downstream has to deal with any overflow.

Useful when one applies one of the custom-parameter onBackpressureXXX operators.

Public Methods

public static BackpressureStrategy valueOf (String name)

public static final BackpressureStrategy[] values ()