Crate tor_async_utils

Help

Expand description

§tor-async-utils

Utilities (low-level) for Tor

Miscellaneous futures-related utilities for tor-* and arti-*.

This crate lives near the bottom of the Tor crate stack.

If you find anything in this crate generally useful, it should probably move out into a crate of its own.

License: MIT OR Apache-2.0

join_read_write 🔒: Join a readable and writeable into a single AsyncRead + AsyncWrite
peekable_stream: Provides utilities for peeking at items in [futures::Stream].
prepare_send 🔒: Extension trait for using [Sink] more safely.
sink_close_channel 🔒: SinkCloseChannel
sink_try_send 🔒: SinkTrySend
sinkext 🔒: Extension trait for Sink.
stream_peek: StreamUnobtrusivePeeker
watch 🔒: Extension trait for more efficient use of [postage::watch].

DropNotifyWatchSender: Wrapper for postage::watch::Sender that sends DropNotifyEof::eof() when dropped
JoinReadWrite: Async readable/writeable that dispatches reads to R and writes to W
MpscOtherSinkTrySendError: [mpsc::Sender::try_send] returned an uncategorisable error
SinkPrepareSendFuture: Future for SinkPrepareExt::prepare_send_from
SinkSendable: A [Sink] which is ready to receive an item

DropNotifyEofSignallable: Values that can signal EOF
PostageWatchSenderExt: Extension trait for some postage::watch::Sender to provide maybe_send
SinkCloseChannel: A [Sink] with a close_channel method like [futures::channel::mpsc::Sender’s]
SinkExt: Extension trait for Sink
SinkPrepareExt: Extension trait for [Sink] to add a method for cancel-safe usage.
SinkTrySend: A [Sink] with a try_send method like [futures::channel::mpsc::Sender’s]
SinkTrySendError: Error from SinkTrySend::try_send