EventStreamPipe (Azkarra Framework 0.9.0 API)

Type Parameters:

K - the record-key type.

V - the record-value type.
```
public interface EventStreamPipe<K,V>
```
The EventStreamPipe is used to attached or detach an object that will be responsible to consume records send to an EventStream.

Since:

0.8.0

See Also:

EventStream.open(EventStreamPipe)

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  void onOpen(BlockingRecordQueue<K,V> queue)
  Set the queue from which records are produced.

- Method Detail
  - onOpen
```
void onOpen(BlockingRecordQueue<K,V> queue)
```
    Set the queue from which records are produced.
    
    Parameters:
    
    queue - the BlockingRecordQueue.