Module async.generator

Package org.bsc.async.v5

Interface AsyncGeneratorFlow

public interface AsyncGeneratorFlow

Represents a queue-based asynchronous generator.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	AsyncGeneratorFlow.Builder
static interface	AsyncGeneratorFlow.Dispatcher<E>
static class	AsyncGeneratorFlow.Generator<E>	Inner class to generate asynchronous elements from the queue.
static interface	AsyncGeneratorFlow.Processor<E>
static interface	AsyncGeneratorFlow.Receiver<E>

Method Summary

Static Methods

Modifier and Type	Method	Description
static AsyncGeneratorFlow.Builder	builder()
static <E> AsyncGeneratorFlow.Generator<E>	create(Consumer<AsyncGeneratorFlow.Dispatcher<E>> emitter)
static <E> AsyncGeneratorFlow.Generator<E>	create(AsyncGeneratorFlow.Processor<E> processor)

Method Details

builder

static AsyncGeneratorFlow.Builder builder()

create

static <E> AsyncGeneratorFlow.Generator<E> create(Consumer<AsyncGeneratorFlow.Dispatcher<E>> emitter)

create

static <E> AsyncGeneratorFlow.Generator<E> create(AsyncGeneratorFlow.Processor<E> processor)