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

CreateRequestHandlerAndData 🔒

If the channel is configured to handle CREATE* requests, this contains anything that is needed solely for this purpose.

Reactor

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

SpecialOutgoing 🔒

Outgoing cells introduced at the channel reactor

Enums

CtrlMsg

A message telling the channel reactor to do something.

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.

ChannelOutputSink 🔒

Type used by a channel reactor to send cells to the network.

ReactorResultChannel 🔒

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