RingBuffers.Lifted

Documentation

data RingBuffer a

A concurrent, mutable ring buffer that supports atomic updates.

new

Arguments

:: Int

capacity of buffer

-> IO (RingBuffer a)

Return a new ring buffer of the specified size.

clear

Arguments

:: RingBuffer a

buffer to clear

-> IO ()

Reset the buffer to its empty state.

append :: a -> RingBuffer a -> IO ()

Add an item to the end of the buffer.

capacity :: RingBuffer a -> IO Int

Get the maximum number of items the ring can contain

filledLength :: RingBuffer a -> IO Int

Get the current filled length of the ring

latest :: RingBuffer a -> Int -> IO (Maybe a)

Retrieve the \(n\)th most-recently added item of the ring

foldMap :: Monoid b => RingBuffer a -> (a -> IO b) -> IO b

Execute the given action with the items of the ring, accumulating its results.