RxJava 2 2.2.21 · io.reactivex.internal.util.BackpressureHelper

Access	Constructor and Description
private	BackpressureHelper() Utility class.

Method Summary

Modifier and Type	Method and Description
public static long	Returns: the original value before the add add(AtomicLong the AtomicLong holding the current requested value requested, long the value to add, must be positive (not verified) n) Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value.
public static long	Returns: the original value before the add addCancel(AtomicLong the AtomicLong holding the current requested value requested, long the value to add, must be positive (not verified) n) Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value and considers Long.MIN_VALUE as a cancel indication (no addition then).
public static long	Returns: the sum capped at Long.MAX_VALUE addCap(long the first value a, long the second value b) Adds two long values and caps the sum at Long.MAX_VALUE.
public static long	Returns: the product capped at Long.MAX_VALUE multiplyCap(long the first value a, long the second value b) Multiplies two long values and caps the product at Long.MAX_VALUE.
public static long	Returns: the new amount produced(AtomicLong the target field holding the current requested amount requested, long the produced element count, positive (not validated) n) Atomically subtract the given number (positive, not validated) from the target field unless it contains Long.MAX_VALUE.
public static long	Returns: the new amount producedCancel(AtomicLong the target field holding the current requested amount requested, long the produced element count, positive (not validated) n) Atomically subtract the given number (positive, not validated) from the target field if it doesn't contain Long.MIN_VALUE (indicating some cancelled state) or Long.MAX_VALUE (unbounded mode).

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

BackpressureHelper	back to summary
private BackpressureHelper() Utility class.

Method Detail

add	back to summary
public static long add(AtomicLong requested, long n) Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value. Parameters requested:AtomicLong the AtomicLong holding the current requested value n:long the value to add, must be positive (not verified) Returns:long the original value before the add

add

back to summary

public static long add(AtomicLong requested, long n)

Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value.

Parameters

requested:AtomicLong: the AtomicLong holding the current requested value
n:long: the value to add, must be positive (not verified)

Returns:long

the original value before the add

addCancel	back to summary
public static long addCancel(AtomicLong requested, long n) Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value and considers Long.MIN_VALUE as a cancel indication (no addition then). Parameters requested:AtomicLong the AtomicLong holding the current requested value n:long the value to add, must be positive (not verified) Returns:long the original value before the add

addCancel

back to summary

public static long addCancel(AtomicLong requested, long n)

Atomically adds the positive value n to the requested value in the AtomicLong and caps the result at Long.MAX_VALUE and returns the previous value and considers Long.MIN_VALUE as a cancel indication (no addition then).

Parameters

requested:AtomicLong: the AtomicLong holding the current requested value
n:long: the value to add, must be positive (not verified)

Returns:long

the original value before the add

addCap	back to summary
public static long addCap(long a, long b) Adds two long values and caps the sum at Long.MAX_VALUE. Parameters a:long the first value b:long the second value Returns:long the sum capped at Long.MAX_VALUE

addCap

back to summary

public static long addCap(long a, long b)

Adds two long values and caps the sum at Long.MAX_VALUE.

Parameters

a:long: the first value
b:long: the second value

Returns:long

the sum capped at Long.MAX_VALUE

multiplyCap	back to summary
public static long multiplyCap(long a, long b) Multiplies two long values and caps the product at Long.MAX_VALUE. Parameters a:long the first value b:long the second value Returns:long the product capped at Long.MAX_VALUE

multiplyCap

back to summary

public static long multiplyCap(long a, long b)

Multiplies two long values and caps the product at Long.MAX_VALUE.

Parameters

a:long: the first value
b:long: the second value

Returns:long

the product capped at Long.MAX_VALUE

produced	back to summary
public static long produced(AtomicLong requested, long n) Atomically subtract the given number (positive, not validated) from the target field unless it contains Long.MAX_VALUE. Parameters requested:AtomicLong the target field holding the current requested amount n:long the produced element count, positive (not validated) Returns:long the new amount

produced

back to summary

public static long produced(AtomicLong requested, long n)

Atomically subtract the given number (positive, not validated) from the target field unless it contains Long.MAX_VALUE.

Parameters

requested:AtomicLong: the target field holding the current requested amount
n:long: the produced element count, positive (not validated)

Returns:long

the new amount

producedCancel	back to summary
public static long producedCancel(AtomicLong requested, long n) Atomically subtract the given number (positive, not validated) from the target field if it doesn't contain Long.MIN_VALUE (indicating some cancelled state) or Long.MAX_VALUE (unbounded mode). Parameters requested:AtomicLong the target field holding the current requested amount n:long the produced element count, positive (not validated) Returns:long the new amount

producedCancel

back to summary

public static long producedCancel(AtomicLong requested, long n)

Atomically subtract the given number (positive, not validated) from the target field if it doesn't contain Long.MIN_VALUE (indicating some cancelled state) or Long.MAX_VALUE (unbounded mode).

Parameters

requested:AtomicLong: the target field holding the current requested amount
n:long: the produced element count, positive (not validated)

Returns:long

the new amount

public final Class BackpressureHelper

Constructor Summary

Method Summary

Constructor Detail

Method Detail