A experimental Channel in JS

channel.js

// kotlin channel: https://kotlinlang.org/docs/reference/coroutines/channels.html
// golang channel

class Channel {
	constructor() {
		this._s = null
		this._r = null
	}
	send(v) {
		if (this._r) {
			this._r(v)
			this._r = null
			return
		} else {
			if (this._s) throw new Error()
			return new Promise(r => this._s = [r, v] )
		}
	}
	receive() {
		if (this._s) {
			const [r, v] = this._s
			this._s = null
			r()
			return v
		} else {
			if (this._r) throw new Error()
			return new Promise(r => this._r = r)
		}
	}
	async *[Symbol.asyncIterator]() {
		for (;;) yield this.receive()
	}
}

const ch = new Channel()

void async function() {
	for await (const x of ch) console.log(x)
}()

setInterval(() => {
	ch.send((Math.random() * 100) | 0)
}, 100)