Module reactor

Code to handle incoming cells on a channel.

The role of this code is to run in a separate asynchronous task, and routes cells to the right circuits.

TODO: I have zero confidence in the close-and-cleanup behavior here, or in the error handling behavior.

Structs

Reactor

Object to handle incoming cells and background tasks on a channel.

SpecialOutgoing 🔒

Outgoing cells introduced at the channel reactor

Enums

CtrlMsgtesting

A message telling the channel reactor to do something.

Functions

codec_err_to_chan 🔒

Convert err to an Error, under the assumption that it’s happening on an open channel.

Type Aliases

BoxedChannelSink 🔒

A boxed trait object that can sink ChanCells.

BoxedChannelStream 🔒

A boxed trait object that can provide ChanCells.

BoxedChannelStreamOps 🔒

A boxed trait object that can provide additional StreamOps on a BoxedChannelStream.

ReactorResultChannel 🔒

The type of a oneshot channel used to inform reactor users of the result of an operation.