Documentation

Pipeline

Table of Contents

Interfaces

ConcurrentIterator

Classes

DisposedException
Will be thrown from {@see Queue::push()} or used to fail the future returned from {@see Queue::pushAsync()} if the associated iterator is disposed.
Pipeline
A pipeline represents an asynchronous set and provides operations which can be applied over the set.
Queue
Queue is an ordered sequence of values with support for concurrent consumption.

        
On this page

Search results