Creating a readable stream from async iterables

[ducaale]

Is there an equivalent to Node's Readable.from() in Deno?

import {Readable} from 'stream';

function* ids() {
  for (const i = 0; i < 10; i++) {
    yield i;
  }
}

Readable.from(ids());

[kitsonk]

Deno has WHATWG streams built in: https://developer.mozilla.org/en-US/docs/Web/API/ReadableStream. But this might be overkill, and so there is also the BufReader: https://doc.deno.land/https/deno.land/std/io/bufio.ts#BufReader

[ducaale]

Relevant issue and draft for supporting ReadableStream.from() in WHATWG streams.

My use-case was to create a readable stream from an async-iterable so it can be returned as the body of an HTTP response using https://github.com/oakserver/oak. Is there an alternative/more idiomatic approach in Deno?

[danopia]

Perhaps this std import/function readableStreamFromAsyncIterator answers your original question: https://deno.land/[email protected]/io/streams.ts#L50

async function* ids() {
  for (let i = 0; i < 10; i++) {
    yield i;
  }
}

// Create a stream
import {readableStreamFromAsyncIterator} from "https://deno.land/[email protected]/io/streams.ts";
const idStream = readableStreamFromAsyncIterator(ids());

// Consume the stream
import {collect} from "https://uber.danopia.net/deno/observables-with-streams@v1/sinks/collect.ts";
console.log('All IDs:', await collect(idStream));

As long as you're talking about async iterables, that is. If your iterable isn't async then std doesn't have an implementation. The non-async implementation is very basic though: from-iterable.ts