Function stream

packages/platform/browser/src/BrowserHttpClient.ts:305–332

()

  }

  get stream(): Stream.Stream<Uint8Array, E> {
    return Stream.callback<Uint8Array, E>((queue) => {
      let offset = 0
      const onReadyStateChange = () => {
        if (this.source.readyState === 3) {
          const encoded = encoder.encode(this.source.responseText.slice(offset))
          Queue.offerUnsafe(queue, encoded)
          offset = this.source.responseText.length
        } else if (this.source.readyState === 4) {
          const encoded = encoder.encode(this.source.responseText.slice(offset))
          if (offset < this.source.responseText.length) {
            Queue.offerUnsafe(queue, encoded)
          }
          Queue.endUnsafe(queue)
        }
      }
      const onError = () => {
        Queue.failCauseUnsafe(queue, Cause.fail(this.onError(this.source.statusText)))
      }
      this.source.addEventListener("readystatechange", onReadyStateChange)
      this.source.addEventListener("error", onError)
      onReadyStateChange()
      return Effect.sync(() => {
        this.source.removeEventListener("readystatechange", onReadyStateChange)
        this.source.removeEventListener("error", onError)
      })
    })
  }

  _arrayBufferEffect: Effect.Effect<ArrayBuffer, E> | undefined
  get arrayBuffer(): Effect.Effect<ArrayBuffer, E> {