throttle-io-stream: Throttler between arbitrary IO producer and consumer functions

[ bsd3, concurrency, library ] [ Propose Tags ]

This packages provides functionality for throttling IO using general IO callbacks. The throttling depends on a provided configuration. The supported throttling modes are producer throttling, consumer throttling or producer & consumer throttling.


[Skip to Readme]

Modules

[Index]

Downloads

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

Versions [RSS] 0.2.0.0, 0.2.0.1
Dependencies async, base (>=4.7 && <5), clock, stm, stm-chans [details]
License BSD-3-Clause
Copyright (c) 2017 Moritz Schulte
Author Moritz Schulte
Maintainer mtesseract@silverratio.net
Category Concurrency
Home page https://github.com/mtesseract/throttle-io-stream#readme
Bug tracker https://github.com/mtesseract/throttle-io-stream/issues
Source repo head: git clone https://github.com/mtesseract/throttle-io-stream
Uploaded by mtesseract at 2017-09-03T21:11:24Z
Distributions
Reverse Dependencies 1 direct, 1 indirect [details]
Downloads 2074 total (9 in the last 30 days)
Rating (no votes yet) [estimated by Bayesian average]
Your Rating
  • λ
  • λ
  • λ
Status Docs available [build log]
Last success reported on 2017-09-03 [all 1 reports]

Readme for throttle-io-stream-0.2.0.1

[back to package description]

throttle-io-stream Hackage version Stackage version Build Status

About

This packages provides throttling functionality for arbitrary IO producers and consumers. The core function exported is the following:

throttle :: ThrottleConf a     -- ^ Throttling configuration
         -> IO (Maybe a)       -- ^ Input callback
         -> (Maybe a -> IO ()) -- ^ Output callback
         -> IO (Async ())      -- ^ Returns an async handler for this
                               -- throttling process

This will spawn asynchronous operations that

  1. consume data using the provided input callback and write it into an internal buffering queue and

  2. produce data from the buffering queue using the provided consumer callback.