Function start

packages/effect/test/Channel.test.ts:127–131

(controller)

          evaluate: () =>
            new ReadableStream<number>({
              start(controller) {
                controller.enqueue(1)
                controller.enqueue(2)
                controller.close()
              }
            }),
          onError: (error) => error
        }).pipe(Channel.runCollect)