Pipe (Hazelcast Root 3.8-EA API)

Type Parameters:

E - type of elements in the pipe.

All Known Subinterfaces:

QueuedPipe<E>

All Known Implementing Classes:

ManyToOneConcurrentArrayQueue, OneToOneConcurrentArrayQueue
```
public interface Pipe<E>
```
A container for items processed in sequence.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`long`	`addedCount()` The number of items added to this container since creation.
`int`	`capacity()` The maximum capacity of this container to hold items.
`int`	`drain(Consumer<E> elementHandler)` Invoke a `Consumer` callback on each elements to drain the collection of elements until it is empty.
`int`	`drainTo(Collection<? super E> target, int limit)` Drain available elements into the provided `Collection` up to a provided maximum limit of elements.
`int`	`remainingCapacity()` Get the remaining capacity for elements in the container given the current size.
`long`	`removedCount()` The number of items removed from this container since creation.

- Method Detail
  - addedCount
```
long addedCount()
```
    The number of items added to this container since creation.
    
    Returns:
    
    the number of items added.
  - removedCount
```
long removedCount()
```
    The number of items removed from this container since creation.
    
    Returns:
    
    the number of items removed.
  - capacity
```
int capacity()
```
    The maximum capacity of this container to hold items.
    
    Returns:
    
    the capacity of the container.
  - remainingCapacity
```
int remainingCapacity()
```
    Get the remaining capacity for elements in the container given the current size.
    
    Returns:
    
    remaining capacity of the container
  - drain
```
int drain(Consumer<E> elementHandler)
```
    Invoke a Consumer callback on each elements to drain the collection of elements until it is empty. If possible, implementations should use smart batching to best handle burst traffic.
    
    Parameters:
    
    elementHandler - to callback for processing elements
    
    Returns:
    
    the number of elements drained
  - drainTo
```
int drainTo(Collection<? super E> target,
            int limit)
```
    Drain available elements into the provided Collection up to a provided maximum limit of elements. If possible, implementations should use smart batching to best handle burst traffic.
    
    Parameters:
    
    target - in to which elements are drained.
    
    limit - of the maximum number of elements to drain.
    
    Returns:
    
    the number of elements actually drained.

Interface Pipe<E>

Method Summary

Method Detail

addedCount

removedCount

capacity

remainingCapacity

drain

drainTo