Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	BackpressureOverflow.DropLatest Drop most recent items, but not `onError` nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).
pack-priv static class	BackpressureOverflow.DropOldest Drop oldest items from the buffer making room for newer ones.
pack-priv static class	BackpressureOverflow.Error `onError` a MissingBackpressureException and unsubscribe from source.
public static interface	BackpressureOverflow.Strategy Represents a callback called when a value is about to be dropped due to lack of downstream requests.

Field Summary

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

Access	Constructor and Description
private	BackpressureOverflow()

Field Detail

ON_OVERFLOW_DEFAULT	back to summary
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DEFAULT By default, signal a MissingBackressureException due to lack of requests.

ON_OVERFLOW_DROP_LATEST	back to summary
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_LATEST Drop the latest value.

ON_OVERFLOW_DROP_OLDEST	back to summary
public static final BackpressureOverflow.Strategy ON_OVERFLOW_DROP_OLDEST Drop the oldest value in the buffer.

ON_OVERFLOW_ERROR	back to summary
public static final BackpressureOverflow.Strategy ON_OVERFLOW_ERROR Signal a MissingBackressureException due to lack of requests.

BackpressureOverflow	back to summary
private BackpressureOverflow()

rx back to summary

pack-priv final Class BackpressureOverflow.DropLatest

Class Inheritance

extends Object
implements Strategy

java.lang.Object
rx.BackpressureOverflow.DropLatest

All Implemented Interfaces

rx.BackpressureOverflow.Strategy

Drop most recent items, but not onError nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).

Field Summary

Modifier and Type	Field and Description
pack-priv static final BackpressureOverflow.DropLatest	INSTANCE

Constructor Summary

Access	Constructor and Description
private	DropLatest()

Method Summary

Modifier and Type	Method and Description
public boolean	mayAttemptDrop() Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
pack-priv static final BackpressureOverflow.DropLatest INSTANCE

Constructor Detail

DropLatest	back to summary
private DropLatest()

Method Detail

mayAttemptDrop	back to summary
public boolean mayAttemptDrop() Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure. Returns:boolean true to request drop of the oldest item, false to drop the newest. Annotations @Override

mayAttemptDrop

back to summary

public boolean mayAttemptDrop()

Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Returns:boolean

true to request drop of the oldest item, false to drop the newest.

Annotations

@Override

rx back to summary

pack-priv final Class BackpressureOverflow.DropOldest

Class Inheritance

extends Object
implements Strategy

java.lang.Object
rx.BackpressureOverflow.DropOldest

All Implemented Interfaces

rx.BackpressureOverflow.Strategy

Drop oldest items from the buffer making room for newer ones.

Field Summary

Modifier and Type	Field and Description
pack-priv static final BackpressureOverflow.DropOldest	INSTANCE

Constructor Summary

Access	Constructor and Description
private	DropOldest()

Method Summary

Modifier and Type	Method and Description
public boolean	mayAttemptDrop() Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
pack-priv static final BackpressureOverflow.DropOldest INSTANCE

Constructor Detail

DropOldest	back to summary
private DropOldest()

Method Detail

mayAttemptDrop	back to summary
public boolean mayAttemptDrop() Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure. Returns:boolean true to request drop of the oldest item, false to drop the newest. Annotations @Override

mayAttemptDrop

back to summary

public boolean mayAttemptDrop()

Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Returns:boolean

true to request drop of the oldest item, false to drop the newest.

Annotations

@Override

rx back to summary

pack-priv final Class BackpressureOverflow.Error

Class Inheritance

extends Object
implements Strategy

java.lang.Object
rx.BackpressureOverflow.Error

All Implemented Interfaces

rx.BackpressureOverflow.Strategy

onError a MissingBackpressureException and unsubscribe from source.

Field Summary

Modifier and Type	Field and Description
pack-priv static final BackpressureOverflow.Error	INSTANCE

Constructor Summary

Access	Constructor and Description
private	Error()

Method Summary

Modifier and Type	Method and Description
public boolean	mayAttemptDrop() Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
pack-priv static final BackpressureOverflow.Error INSTANCE

Constructor Detail

Error	back to summary
private Error()

Method Detail

mayAttemptDrop	back to summary
public boolean mayAttemptDrop() throws MissingBackpressureException Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop. Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop. Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure. Returns:boolean true to request drop of the oldest item, false to drop the newest. Annotations @Override Exceptions MissingBackpressureException: if the strategy should signal MissingBackpressureException

mayAttemptDrop

back to summary

public boolean mayAttemptDrop() throws MissingBackpressureException

Implements rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Doc from rx.BackpressureOverflow.Strategy.mayAttemptDrop.

Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Returns:boolean

true to request drop of the oldest item, false to drop the newest.

Annotations

@Override

Exceptions

MissingBackpressureException:: if the strategy should signal MissingBackpressureException

rx back to summary

public Interface BackpressureOverflow.Strategy

Known Direct Implementers: rx.BackpressureOverflow.DropOldest, rx.BackpressureOverflow.DropLatest, rx.BackpressureOverflow.Error

Represents a callback called when a value is about to be dropped due to lack of downstream requests.

Method Summary

Modifier and Type	Method and Description
public boolean	Returns: true to request drop of the oldest item, false to drop the newest. mayAttemptDrop() Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Method Detail

mayAttemptDrop	back to summary
public boolean mayAttemptDrop() throws MissingBackpressureException Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure. Returns:boolean true to request drop of the oldest item, false to drop the newest. Exceptions MissingBackpressureException: if the strategy should signal MissingBackpressureException

mayAttemptDrop

back to summary

public boolean mayAttemptDrop() throws MissingBackpressureException

Whether the Backpressure manager should attempt to drop the oldest item, or simply drop the item currently causing backpressure.

Returns:boolean

true to request drop of the oldest item, false to drop the newest.

Exceptions

MissingBackpressureException:: if the strategy should signal MissingBackpressureException

public final Class BackpressureOverflow

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

pack-priv final Class BackpressureOverflow.DropLatest

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class BackpressureOverflow.DropOldest

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class BackpressureOverflow.Error

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface BackpressureOverflow.Strategy

Method Summary

Method Detail