Function push

packages/opencode/test/cli/run/stream.transport.test.ts:130–134

(value: T)

  return {
    stream: wrapped,
    push(value: T) {
      list.push(value)
      wake?.()
      wake = undefined
    },
    close() {
      done = true
      wake?.()