Class JsonMessage

samples/01-basic-creation.ts:186–193

  {
    // Define a class that implements the ToStreamable protocol
    class JsonMessage {
      constructor(private data: object) {}

      // The protocol method - returns sync streamable yield
      [Stream.toStreamable](): string {
        return JSON.stringify(this.data);
      }
    }

    // Create a generator that yields JsonMessage objects
    function* messageSource() {