Core Async JS ·     

__CoreAsyncJS__ is a JS library that implements the core aspects of the CSP (Communicating Sequential Processes) patterns. CoreAsyncJS uses _Channels_ to synchronise concurrent processes. It is inspired from the Clojure core.async library and designed to be used with the npm package 'co' (shipped with this package). It also exposes composable APIs called _transducers_ to help filter, map and, more generally speaking, reduce streams of data.

``js
const { co, Channel } = require('core-async')

// Example of two processes running concurrently.

// Channels 'inChan' and 'outChan' are used to synchronise process 1 and process 2.
const inChan = new Channel()
const outChan = new Channel()

// Concurrent process 1. This process encapsulates logic that does not care
// when or how the message put on 'inChan' is processed. It only knows that
// after it has been processed, it is available on 'outChan'.
//
co(function *(){
while (true) {
yield inChan.put(Math.random())
const msg = outChan.stake()
if (msg)
console.log(msg)
}
})

// Concurrent process 2. This process encapsulates logic that does not care
// when or how the message was put on the 'inChan'. It only knows that when
// it is available, it has to process it and then potentially put it back on
// the 'outChan' channel. This process also does not care of what happens to
// that processed message after it has been put on the 'outChan' channel.
co(function *(){
while (true) {
const val = yield inChan.take()
if (val >= 0.250 && val <= 0.252)
yield outChan.put(We've found a winner: ${val})
}
})

console.log('Program has started.')
`

For more advanced examples, please refer to the Examples sections.




Table of Contents

> * Install
> * APIs
> - Channel
> - Buffered vs Unbuffered Channels
> - Dropping and Sliding Channels
> - put - take - sput - stake
> - Composable transducers
> - utils
> - alts
> - merge
> - timeout
> - subscribe
> - throttle
> * Common Patterns & Idiomatic Style
> - Dealing With Timeout
> - Why you should always close your channel when you're done with it
> * Examples
> - Chat between two agents
> - Monitoring Stock Prices
> * About Neap
> * License




Install


`
npm i core-async
`

APIs

Channel

The Channel object supports three different signatures:
- new Channel( buffer,