Method read

plugins/recorder-resources/src/stream.ts:26–36

()

  private awaitingResolve: ((val: ChunkReadResult | Promise<ChunkReadResult>) => void) | null = null

  public async read (): Promise<ChunkReadResult> {
    if (this.done && this.chunks.length === 0) {
      return { done: true, value: undefined }
    }
    if (this.chunks.length === 0) {
      return await new Promise<ChunkReadResult>((resolve) => {
        this.awaitingResolve = resolve
      })
    }
    return { done: false, value: this.chunks.shift() }
  }

  public push (blob: Blob): void {
    if (this.done) {