Crate vector_stream

Source

Modules§

batcher
expiration_map

Structs§

BatcherSettings
Controls the behavior of the batcher in terms of batch size and flush interval.
ConcurrentMap
Driver
Drives the interaction between a stream of items and a service which processes them asynchronously.
ExpirationQueue
A KeyedTimer based on DelayQueue.
PartitionedBatcher

Traits§

DriverResponse