Crate tor_async_utils 

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

Re-exports

pub use oneshot_fused_workaround as oneshot;

Modules

counting_streams

A facility for an MPSC channel that counts the number of outstanding entries on the channel.

peekable_stream

Provides utilities for peeking at items in futures::Stream.

stream_peek

StreamUnobtrusivePeeker

Structs

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

Enums

ErasedSinkTrySendError

Type-erased error for SinkTrySend::try_send

Traits

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

Functions

mpsc_channel_no_memquota

Precisely futures::channel::mpsc::channel