rxjava 1.3.8 · rx.internal.producers.ProducerArbiter

Field Summary

Modifier and Type	Field and Description
pack-priv Producer	currentProducer
pack-priv boolean	emitting
pack-priv long	missedProduced
pack-priv Producer	missedProducer
pack-priv long	missedRequested
pack-priv static final Producer	NULL_PRODUCER
pack-priv long	requested

Constructor Summary

Access	Constructor and Description
public	ProducerArbiter()

Method Summary

Modifier and Type	Method and Description
public void	emitLoop()
public void	produced(long n)
public void	request(long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace n) Implements rx.Producer.request. Request a certain maximum number of items from this Producer.
public void	setProducer(Producer newProducer)

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

Field Detail

currentProducer	back to summary
pack-priv Producer currentProducer

emitting	back to summary
pack-priv boolean emitting

missedProduced	back to summary
pack-priv long missedProduced

missedProducer	back to summary
pack-priv Producer missedProducer

missedRequested	back to summary
pack-priv long missedRequested

NULL_PRODUCER	back to summary
pack-priv static final Producer NULL_PRODUCER

requested	back to summary
pack-priv long requested

Constructor Detail

ProducerArbiter	back to summary
public ProducerArbiter()

Method Detail

emitLoop	back to summary
public void emitLoop()

produced	back to summary
public void produced(long n)

request back to summary

request	back to summary
public void request(long n) Implements rx.Producer.request. Doc from rx.Producer.request. Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass `Long.MAX_VALUE` to this method. Requests are additive but if a sequence of requests totals more than `Long.MAX_VALUE` then `Long.MAX_VALUE` requests will be actioned and the extras may be ignored. Arriving at `Long.MAX_VALUE` by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in `Long.MAX_VALUE` requests being actioned only. request(100); request(Long.MAX_VALUE-1); Parameters n:long the maximum number of items you want this Producer to produce, or `Long.MAX_VALUE` if you want the Producer to produce items at its own pace Annotations @Override

public void request(long n)

Implements rx.Producer.request.

Doc from rx.Producer.request.

Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, pass Long.MAX_VALUE to this method.

Requests are additive but if a sequence of requests totals more than Long.MAX_VALUE then Long.MAX_VALUE requests will be actioned and the extras may be ignored. Arriving at Long.MAX_VALUE by addition of requests cannot be assumed to disable backpressure. For example, the code below may result in Long.MAX_VALUE requests being actioned only.

request(100);
request(Long.MAX_VALUE-1);

Parameters

n:long: the maximum number of items you want this Producer to produce, or Long.MAX_VALUE if you want the Producer to produce items at its own pace

Annotations

@Override