x/rimbu/stream/async/async-streamable.ts
123456789101112import type { AsyncStream } from '../../stream/async/index.ts';export interface AsyncStreamable<T> { asyncStream(): AsyncStream<T>;}export namespace AsyncStreamable { export interface NonEmpty<T> { asyncStream(): AsyncStream.NonEmpty<T>; }}