A PanicGuard wraps a Sender<Item=Result<T,()>> and sends an Err(()) through it if the PanicGuard is dropped while the current thread is panicking. Thi

Things which implement this can be used with the Pipeliner library.

This is an intermediate data structure which allows you to configure how your pipeline should run.

An unorderd output iterator which manages its own threads.

Implements the ordered variant of PipelineIter.

Wraps an iterator. *This* Iterator's next() will call the inner one, create a promise, enqueue the promise_rx on an output channel, and return the (ne

This lets me access a Result's Ok/Err types as associated types:

A trait for the common functionality in mpsc::Sender mpsc::SyncSender crossbeam_channel::Sender

An iterator which can be safely shared between threads.