Streamly.Internal.Data.Stream.Channel.Worker

Collecting results from child workers in a streamed fashion

Documentation

data Work

Constructors

BlockWait NanoSecond64

PartialWorker Count

ManyWorkers Int Count

Instances

Show Work

Defined in Streamly.Internal.Data.Stream.Channel.Worker

Methods

showsPrec :: Int -> Work -> ShowS

show :: Work -> String

showList :: [Work] -> ShowS

estimateWorkers :: Limit -> Count -> Count -> NanoSecond64 -> NanoSecond64 -> NanoSecond64 -> LatencyRange -> Work

isBeyondMaxRate :: Limit -> IORef Int -> YieldRateInfo -> IO Bool

workerRateControl :: Limit -> IORef Int -> YieldRateInfo -> WorkerInfo -> IO Bool

CAUTION! this also updates the yield count and therefore should be called only when we are actually yielding an element.

Send Events

sendWithDoorBell :: IORef ([ChildEvent a], Int) -> MVar () -> ChildEvent a -> IO Int

sendYield :: Limit -> Limit -> IORef Int -> Maybe WorkerInfo -> Maybe YieldRateInfo -> IORef ([ChildEvent a], Int) -> MVar () -> ChildEvent a -> IO Bool

Returns whether the worker should continue (True) or stop (False).

sendStop :: IORef Int -> Maybe WorkerInfo -> Maybe YieldRateInfo -> IORef ([ChildEvent a], Int) -> MVar () -> IO ()

handleChildException :: IORef ([ChildEvent a], Int) -> MVar () -> SomeException -> IO ()