Chan is:package
Generalized stream processors
A mutual generalization of
pipes and
machines; a library
for exploring a particular corner of the design space of streaming IO
(and other related tasks) in Haskell.
Not on Stackage, so not searched.
Stateful monad transformer based on monoidal actions
Not on Stackage, so not searched.
Stateful monad transformer based on monoidal actions
Not on Stackage, so not searched.
Concurrent Chans as read/write pairs. Also provides generic Chan pair class.
Not on Stackage, so not searched.
Parse VCS changelogs into ChangeLogs
Not on Stackage, so not searched.
Changelog manager for Git projects.
Not on Stackage, so not searched.
Stateful monad transformer based on monoidal actions
Not on Stackage, so not searched.
Stateful monad transformer based on monoidal actions
Additional types of channels for STM.
Additional types of channels for STM.
Fast concurrent queues with a Chan-like API, and more
This library provides implementations of concurrent FIFO queues (for
both general boxed and primitive unboxed values) that are fast,
perform well under contention, and offer a Chan-like interface. The
library may be of limited usefulness outside of x86 architectures
where the fetch-and-add instruction is not available.
We export several variations of our design; some support additional
functionality while others try for lower latency by removing features
or making them more restrictive (e.g. in the
Unboxed
variants).
- Unagi: a general-purpose near drop-in replacement for
Chan.
- Unagi.Unboxed: like Unagi but specialized for
primitive types; this may perform better if a queue grows very
large.
- Unagi.Bounded: a bounded variant with blocking and
non-blocking writes, and other functionality where a notion of the
queue's capacity is required.
- Unagi.NoBlocking: lowest latency implementations for when
blocking reads aren't required.
- Unagi.NoBlocking.Unboxed: like Unagi.NoBlocking
but for primitive types.
Some of these may be deprecated in the future if they are found to
provide little performance benefit, or no unique features; you should
benchmark and experiment with them for your use cases, and please
submit pull requests for additions to the benchmark suite that reflect
what you find.
Here is an example benchmark measuring the time taken to concurrently
write and read 100,000 messages, with work divided amongst increasing
number of readers and writers, comparing against the top-performing
queues in the standard libraries. The inset graph shows a zoomed-in
view on the implementations here.
Implementation of bounded channels.
This library introduces BoundedChan. BoundedChans differ from Chans in
that they are guaranteed to contain no more than a certain number of
elements.
Not on Stackage, so not searched.
Closable, fair, single-wakeup channel type that avoids 0 reader space leaks.
Not on Stackage, so not searched.
Types and serialization for HTTP
Not on Stackage, so not searched.
Amazon Mechanical Turk SDK.
Not on Stackage, so not searched.
Instant, two-party Bitcoin payments
Not on Stackage, so not searched.
Helpers for generating tests for broadcast-chan
Not on Stackage, so not searched.
Binding to the Enchant library
Not on Stackage, so not searched.
A Haskell client for https://exchangeratesapi.io/
Not on Stackage, so not searched.
Perform HTTP Requests
Not on Stackage, so not searched.
StackExchange API interface
Not on Stackage, so not searched.
Scrape websites for changes
Not on Stackage, so not searched.
Hides duplicating channels when broadcasting
Not on Stackage, so not searched.
Unagi chan based websocket client
Not on Stackage, so not searched.
Read single output from an array of inputs - channels with priorities