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

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]