Chan | /channel.ts | easyts@0.1.2

class Chan

implements ReadChannel<T>, WriteChannel<T>

import { Chan } from "https://deno.land/x/easyts@0.1.2/channel.ts";

The concrete realization of Channel

Examples

use

function sum(s: Array<number>, c: WriteChannel<number>) {
    let sum = 0
    for (const v of s) {
        sum += v
    }
    c.write(sum) // send sum to c
}
async function main() {
    const s = [7, 2, 8, -9, 4, 0]
    const c = new Chan<number>()
    sum(s.slice(0, s.length / 2), c)
    sum(s.slice(s.length / 2), c)

    const [x, y] = [await c.read(), await c.read()] // receive from c

    console.log(x, y, x + y)
}
main()

buffered

    const ch = new Chan<number>(2)
    ch.write(1)
    ch.write(2)
    let [v,ok]= ch.readRaw()
    console.log(v,ok)
    v = ch.read()
    console.log(v)

Constructors

new

Chan(buf?)

Type Parameters

Properties

private

rw_: RW<T>

Low-level read and write implementation

readonly

capacity: number

Returns how much data the channel has buffered

readonly

isClosed: boolean

Returns whether the channel is closed

readonly

length: number

Returns the channel buffer size

readonly

rw: RW<T>

Methods

close(): boolean

Close the channel, after which the channel will not be able to write, all blocked reads and writes are returned, but the value that has been written to the channel is guaranteed to be fully read

read(): ReadReturn<T>

Read a value from the channel, block if there is no value to read, and return until there is a value or the channel is closed

readCase(): ReadCase<T>

Create a case for select to read

readRaw(): ReadRawReturn<T>

Read a value from the channel, block if there is no value to read, and return until there is a value or the channel is closed

tryRead(): IteratorResult<T> | undefined

Attempts to read a value from the channel, returns undefined if no value is readable, returns {done:true} if the channel is closed