Class SmartBuffer

samples/01-basic-creation.ts:298–311

  // Object can implement both protocols (sync and async)
  {
    class SmartBuffer {
      constructor(private content: string) {}

      // Sync version - used in sync contexts
      [Stream.toStreamable](): string {
        return this.content;
      }

      // Async version - preferred in async contexts, can do async processing
      async *[Stream.toAsyncStreamable]() {
        // Could do async compression, transformation, etc.
        yield `[async] ${this.content}`;
      }
    }

    // In async context, toAsyncStreamable is preferred
    const asyncText = await Stream.text(Stream.from([new SmartBuffer('hello')]));