Function fakeStreamFactory

apps/sim/providers/streaming-execution.test.ts:13–24

* Builds a fake stream factory mirroring the providers' `createReadableStreamFrom*` * helpers: it returns a sentinel stream and synchronously invokes the drain * callback so the test can assert the populated output without a real stream.

(
  drain: (handles: { output: NormalizedBlockOutput; finalizeTiming: () => void }) => void
)

 * callback so the test can assert the populated output without a real stream.
 */
function fakeStreamFactory(
  drain: (handles: { output: NormalizedBlockOutput; finalizeTiming: () => void }) => void
) {
  const stream = new ReadableStream()
  return {
    stream,
    createStream: (handles: { output: NormalizedBlockOutput; finalizeTiming: () => void }) => {
      drain(handles)
      return stream
    },
  }
}

describe('createStreamingExecution', () => {
  const providerStartTime = 1_000