OperatorGroupBy.GroupByProducer

java.lang.Object
- rx.internal.operators.OperatorGroupBy.GroupByProducer

All Implemented Interfaces:: Producer

Enclosing class:: OperatorGroupBy<T,K,V>

public static final class OperatorGroupBy.GroupByProducer
extends java.lang.Object
implements Producer

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  (package private) OperatorGroupBy.GroupBySubscriber<?,?,?> parent
- Constructor Summary
  
  Constructors
  Constructor Description
  
  GroupByProducer(OperatorGroupBy.GroupBySubscriber<?,?,?> parent)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void request(long n)
  Request a certain maximum number of items from this Producer.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - parent
```
final OperatorGroupBy.GroupBySubscriber<?,?,?> parent
```
- Constructor Detail
  - GroupByProducer
```
public GroupByProducer(OperatorGroupBy.GroupBySubscriber<?,?,?> parent)
```
- Method Detail
  - request
```
public void request(long n)
```
    Description copied from interface: Producer
    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);
    Specified by:
    
    request in interface Producer
    
    Parameters:
    
    n - 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