Function stream

packages/platform-browser/src/internal/httpClient.ts:217–242

()

  }

  get stream(): Stream.Stream<Uint8Array, E> {
    return Stream.async<Uint8Array, E>((emit) => {
      let offset = 0
      const onReadyStateChange = () => {
        if (this.source.readyState === 3) {
          emit.single(encoder.encode(this.source.responseText.slice(offset)))
          offset = this.source.responseText.length
        } else if (this.source.readyState === 4) {
          if (offset < this.source.responseText.length) {
            emit.single(encoder.encode(this.source.responseText.slice(offset)))
          }
          emit.end()
        }
      }
      const onError = () => {
        emit.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> {