Module sink_blocker 

Implement SinkBlocker, a wrapper type to allow policy-based blocking of a [futures::Sink].

Modules

boolean_policy 🔒

Implement a sink-blocking policy based on a simple blocked/unblocked status.

counting_policy 🔒

Implement a sink-blocking policy that allows a limited number of items to be sent.

Structs

SinkBlocker 🔒

A wrapper for a [futures::Sink] that allows its blocking status to be turned on and off according to a policy.

Traits

Policy 🔒

A policy that describes whether cells can be sent on a SinkBlocker.