Function wrap

pub fn wrap(
    input: Executor,
    actor_id: ActorId,
) -> (SubtaskHandle, SubtaskRxExecutor)

Wrap an executor into a subtask and a thin receiver executor, connected by a channel with a buffer size of 1.

Used when there’re multiple stateful executors in an actor. These subtasks can be concurrently executed to improve the I/O performance, while the computing resource can be still bounded to a single thread.