deno-streams

[WIP] WHATWG streams API by TypeScript for deno

See: https://streams.spec.whatwg.org/

compatibility table

• ReadableStream
  • new ReadableStream(underlyingSource = {}, strategy = {})
  • get locked
  • cancel(reason)n
  • pipeThrough({ writable, readable }, { preventClose, preventAbort, preventCancel, signal } = {})
  • pipeTo(dest, { preventClose, preventAbort, preventCancel, signal } = {})
  • tee()
• WritableStream
  • new WritableStream( underlyingSink = {}, strategy = {} )
  • get locked
  • abort( reason )
  • getWriter()
• TransformStream
  • new TransformStream( transformer = {}, writableStrategy = {}, readableStrategy = {} )
  • get readable
  • get writable
• ByteLengthQueuingStrategy
• CountQueuingStrategy

Usage

import { ReadableStream } from "https://denopkg.com/keroxp/deno-streams/readable_stream.ts"
import { WritableStream } from "https://denopkg.com/keroxp/deno-streams/writable_stream.ts"

const src = [0,1,2,3,4]
let i = 0
const dest = []
const readable = new ReadableStream<number>({
    pull: controller => {
        controller.enqueue(src[i++])
        if (i >= src.length) controller.close()
    }
})
const writable = new WritableStream<number>({
    write: chunk => {
        dest.push(chunk)
    }
})
await readable.pipeTo(writable)
console.log(dest) // => [0,1,2,3,4]