Crate ruchei_route

Sinks with routing inspired by ZeroMQ’s ROUTER sockets.

This model sits somewhere between explicit connection management and ZMQ-like routing trying to be a reasonable abstraction around both, with some trade-offs.

Sinks

• RouteSink::poll_ready_any
• RouteSink::start_send
• RouteSink::poll_flush_all
• RouteSink::poll_close

Proper RouteSinks

• RouteSink::poll_ready
• RouteSink::start_send
• RouteSink::poll_flush
• RouteSink::poll_close

RouteSink as a trait union

• RouteSink::is_routing

Dynamicity

Object safety

RouteSink method is object safe.

However, we don’t provide any methods to upcast to Sink, since we believe plain Sink and RouteSink traits don’t represent our target usecases, specifically networking, which involve Streams as a necessary component of the object. Since this crate doesn’t depend on futures-core, we don’t provide dyn Stream + ... either. Another consideration is to provide mechanisms for creating upcasting instead of providing upcasting itself, to, for example, allow for a more efficient FFI functionality.

FFI

Coming Soon…

Structs

• Unroute
  Assert that RouteSink is derived from Sink.
• WithRoute
  Sink for RouteSink and a specific route.

Traits

• RouteExt
  Extension trait to make WithRoute from some mutable (pinned) reference to RouteSink.
• RouteSink
  Sink with route provided to some methods.