List of all items

Structs

• ConsumeAtLeastError
• ProduceAtLeastError
• channels::advanced::sssr::Receiver
• channels::advanced::sssr::Sender
• channels::advanced::sssr::State
• channels::sssr::Receiver
• channels::sssr::Sender
• codec::adaptors::Decoder
• codec::adaptors::Encoder
• codec::endian::I128BE
• codec::endian::I128LE
• codec::endian::I16BE
• codec::endian::I16LE
• codec::endian::I32BE
• codec::endian::I32LE
• codec::endian::I64BE
• codec::endian::I64LE
• codec::endian::I8BE
• codec::endian::I8LE
• codec::endian::U128BE
• codec::endian::U128LE
• codec::endian::U16BE
• codec::endian::U16LE
• codec::endian::U32BE
• codec::endian::U32LE
• codec::endian::U64BE
• codec::endian::U64LE
• codec::endian::U8BE
• codec::endian::U8LE
• consumer::Buffered
• consumer::BulkBuffered
• consumer::BulkScrambled
• consumer::Chain
• consumer::CloningChain
• consumer::ConsumeWhile
• consumer::ErrorImmediately
• consumer::Filter
• consumer::Full
• consumer::Limit
• consumer::MapAsyncError
• consumer::MapAsyncFinal
• consumer::MapAsyncItem
• consumer::MapError
• consumer::MapFinal
• consumer::MapItem
• consumer::MoveIntoOwnedSlice
• consumer::MoveIntoSlice
• consumer::Scrambled
• consumer::Stats
• consumer::TestConsumer
• consumer::TestConsumerBuilder
• consumer::Watch
• consumer::Watcher
• consumer::compat::array::IntoConsumer
• consumer::compat::array::IntoConsumerMut
• consumer::compat::binary_heap::IntoConsumer
• consumer::compat::binary_heap::IntoConsumerMut
• consumer::compat::btree_map::IntoConsumer
• consumer::compat::btree_map::IntoConsumerMut
• consumer::compat::btree_set::IntoConsumer
• consumer::compat::btree_set::IntoConsumerMut
• consumer::compat::fn_mut::ClosureConsumer
• consumer::compat::hash_map::IntoConsumer
• consumer::compat::hash_map::IntoConsumerMut
• consumer::compat::hash_set::IntoConsumer
• consumer::compat::hash_set::IntoConsumerMut
• consumer::compat::linked_list::IntoConsumer
• consumer::compat::linked_list::IntoConsumerMut
• consumer::compat::slice::IntoConsumerBoxed
• consumer::compat::slice::IntoConsumerBoxedMut
• consumer::compat::slice::IntoConsumerMut
• consumer::compat::vec::IntoConsumer
• consumer::compat::vec::IntoConsumerMut
• consumer::compat::vec_deque::IntoConsumer
• consumer::compat::vec_deque::IntoConsumerMut
• consumer::compat::writer::WriterToBulkConsumer
• producer::Buffered
• producer::BulkBuffered
• producer::BulkScrambled
• producer::Chain
• producer::CloneFromOwnedSlice
• producer::CloneFromSlice
• producer::Empty
• producer::ErrorImmediately
• producer::Filter
• producer::Limit
• producer::MapAsyncError
• producer::MapAsyncFinal
• producer::MapAsyncItem
• producer::MapError
• producer::MapFinal
• producer::MapItem
• producer::ProduceWhile
• producer::Scrambled
• producer::Stats
• producer::TestProducer
• producer::TestProducerBuilder
• producer::Watch
• producer::Watcher
• producer::compat::InfiniteIteratorToProducer
• producer::compat::IteratorToProducer
• producer::compat::array::IntoProducer
• producer::compat::array::IntoProducerMut
• producer::compat::array::IntoProducerRef
• producer::compat::binary_heap::IntoProducer
• producer::compat::binary_heap::IntoProducerRef
• producer::compat::btree_map::IntoProducer
• producer::compat::btree_map::IntoProducerMut
• producer::compat::btree_map::IntoProducerRef
• producer::compat::btree_set::IntoProducer
• producer::compat::btree_set::IntoProducerRef
• producer::compat::fn_mut::ClosureProducer
• producer::compat::hash_map::IntoProducer
• producer::compat::hash_map::IntoProducerMut
• producer::compat::hash_map::IntoProducerRef
• producer::compat::hash_set::IntoProducer
• producer::compat::hash_set::IntoProducerRef
• producer::compat::linked_list::IntoProducer
• producer::compat::linked_list::IntoProducerMut
• producer::compat::linked_list::IntoProducerRef
• producer::compat::reader::BufReaderToBulkProducer
• producer::compat::reader::ReaderToBulkProducer
• producer::compat::slice::IntoProducerBoxed
• producer::compat::slice::IntoProducerBoxedMut
• producer::compat::slice::IntoProducerBoxedRef
• producer::compat::slice::IntoProducerMut
• producer::compat::slice::IntoProducerRef
• producer::compat::vec::IntoProducer
• producer::compat::vec::IntoProducerMut
• producer::compat::vec::IntoProducerRef
• producer::compat::vec_deque::IntoProducer
• producer::compat::vec_deque::IntoProducerMut
• producer::compat::vec_deque::IntoProducerRef
• queues::Contiguous
• queues::Elastic
• queues::FaultTolerantElastic
• queues::Unbounded
• queues::UnboundedElastic

Enums

• ConsumeLimitError
• ExpectedFinalError
• PipeError
• ProcessWhileError
• ProduceLimitError
• codec::Blame
• codec::DecodeError
• consumer::BulkConsumerOperation
• consumer::ConsumerOperation
• consumer::Status
• consumer::TestConsumerBuilderError
• prelude::Either
• prelude::Infallible
• producer::BulkProducerOperation
• producer::ProducerOperation
• producer::Status
• producer::TestProducerBuilderError
• queues::dev::QueueOp

Traits

• codec::Decodable
• codec::DecodableCanonic
• codec::Encodable
• codec::EncodableExt
• codec::EncodableKnownLength
• codec::EncodableKnownLengthExt
• codec_relative::RelativeDecodable
• codec_relative::RelativeDecodableCanonic
• codec_relative::RelativeEncodable
• codec_relative::RelativeEncodableExt
• codec_relative::RelativeEncodableKnownLength
• codec_relative::RelativeEncodableKnownLengthExt
• consumer::BulkConsumer
• consumer::BulkConsumerExt
• consumer::Consumer
• consumer::ConsumerExt
• consumer::IntoBulkConsumer
• consumer::IntoConsumer
• producer::BulkProducer
• producer::BulkProducerExt
• producer::IntoBulkProducer
• producer::IntoProducer
• producer::Producer
• producer::ProducerExt
• queues::BoundedQueue
• queues::Queue
• queues::QueueExt

Macros

• consume
• prelude::consume

Functions

• bulk_pipe
• channels::advanced::sssr::new_sssr
• channels::sssr::new_sssr
• codec::adaptors::decoder
• codec::adaptors::encoder
• codec::proptest::assert_codec
• codec::proptest::assert_codec_canonic
• codec::proptest::assert_codec_canonic_and_known_len
• codec::proptest::assert_codec_known_length
• codec_relative::proptest::assert_relative_codec
• codec_relative::proptest::assert_relative_codec_canonic
• codec_relative::proptest::assert_relative_codec_canonic_and_known_len
• codec_relative::proptest::assert_relative_codec_known_length
• consumer::build_test_consumer
• consumer::compat::writer::writer_to_bulk_consumer
• consumer::error_immediately
• consumer::full
• consumer::move_into_owned_slice
• consumer::move_into_slice
• pipe
• producer::build_test_producer
• producer::clone_from_owned_slice
• producer::clone_from_slice
• producer::compat::infinite_iterator_to_producer
• producer::compat::iterator_to_producer
• producer::compat::reader::buf_reader_to_bulk_producer
• producer::compat::reader::reader_to_bulk_producer
• producer::empty
• producer::error_immediately
• queues::dev::assert_fifo_queue
• queues::new_contiguous
• queues::new_contiguous_with
• queues::new_elastic
• queues::new_elastic_with
• queues::new_fault_tolerant_elastic
• queues::new_fault_tolerant_elastic_with
• queues::new_fixed
• queues::new_fixed_with
• queues::new_static
• queues::new_static_with
• queues::new_unbounded
• queues::new_unbounded_elastic
• queues::new_unbounded_elastic_with
• queues::new_unbounded_with