Streaming.Concurrent

Buffers

data Buffer a

unbounded

bounded

latest

newest

Using a buffer

withBuffer

withBufferedTransform

data InBasket a

data OutBasket a

Stream support

writeStreamBasket

withStreamBasket

withMergedStreams

Mapping

withStreamMap

withStreamMapM

withStreamTransform