import { fromAsyncStreamSource } from "https://deno.land/x/rimbu@0.13.1/stream/async-custom/index.ts";
type
{ <T>(source: AsyncStreamSource.NonEmpty<T>): AsyncStream.NonEmpty<T>; <T>(source: AsyncStreamSource<T>): AsyncStream<T>; }
x/rimbu/stream/async-custom/index.ts>fromAsyncStreamSource
import { fromAsyncStreamSource } from "https://deno.land/x/rimbu@0.13.1/stream/async-custom/index.ts";