Async Channels


Channels are queue-like objects _(First In First Out)_ that their enqueue
(send) and dequeue (get) functions are asynchronous (async). By passing them
between asynchronous functions we can synchronize operations between said
functions.

Setup

$3

Released under both npmjs & github packages:


Install:

import (ES Modules):

`js
import { Channel } from "@eyalsh/async_channels";
`

require (CommonJS):

`js
const { Channel } = require("@eyalsh/async_channels");
`

$3

The library is available to import from
deno.land/x/async_channels

`ts
import { Channel } from "https://deno.land/x/async_channels/mod.ts";
`

$3

You can import the library from any CDN that mirrors _npmjs.com_, such as
skypack.dev or
unpkg.com.

`js
import { Channel } from "https://cdn.skypack.dev/@eyalsh/async_channels";
`

Or you can download compiled library from GitHub:

- Latest Release
- All Releases

`js
import { Channel } from "/path/to/async_channels.esm.js";
`

_Note: an IIFE version also exist, if your application doesn't support ES
modules._

`html


`

Examples

- middleware (ping-pong)

- pipeline (even or odd)

- pipeline (lorem-ipsum)

- Message Queue

- static site (todos app)

- `ts
import { Channel, time } from "https://deno.land/x/async_channels/mod.ts";

function produce(num: number) {
return Channel.from((async function* () {
for (let i = 0; i < num; i++) {
await time.timeout(100).get(); // Do some work...
yield i;
}
})());
}

time.timeout(300).get().then(() => console.log("boo"));

for await (const product of produce(4)) {
console.log({ product });
}
``