Module actor

Structs

Actor

Actor is the basic execution unit in the streaming framework.

ActorContext

Shared by all operators of an actor.

Functions

spawn_blocking_drop_stream

Drop the stream in a blocking task to avoid interfering with other actors.

Type Aliases

ActorContextRef