Module builder_async 

Types to build async operators with general shapes.

Structs

AsyncInputHandle

Async handle to an operator’s input stream

AsyncOutputHandle

Button

ButtonHandle

A button that can be used to coordinate an action after all workers have pressed it.

ConnectedToMany

A marker type representing an input connected to many outputs.

ConnectedToOne

A marker type representing an input connected to exactly one output.

Disconnected

A marker type representing a disconnected input.

OperatorBuilder

Builds async operators with generic shape.

PressOnDropButton

Enums

Event

An event of an input stream

Constants

MAX_OUTSTANDING_BYTES

Maximum bytes AsyncOutputHandle::give_fueled emits through one handle before yielding back to timely.

Traits

InputConnection

A trait describing the connection behavior between an input of an operator and zero or more of its outputs.

OutputIndex

A helper trait abstracting over an output handle. It facilitates passing type erased output handles during operator construction. It is not meant to be implemented by users.

ShipUnder

A capability an output handle can ship data under: one capability, or a whole set.

Functions

button

Creates a new coordinated button the worker configuration described by scope.

sole_capability

The one capability of a message in a totally ordered scope.