Method appendFromStream

external/.scrollLibs.js:16650–16723

(input)

    return newParticle
  }
  async appendFromStream(input) {
    var _a, e_1, _b, _c
    const { edgeSymbol, particleBreakSymbol } = this
    let buffer = ""
    const breakRegex = new RegExp(`${particleBreakSymbol}(?!${edgeSymbol})`)
    // Node.js Readable stream
    if (typeof process !== "undefined" && input instanceof require("stream").Readable) {
      try {
        for (var _d = true, input_1 = __asyncValues(input), input_1_1; (input_1_1 = await input_1.next()), (_a = input_1_1.done), !_a; ) {
          _c = input_1_1.value
          _d = false
          try {
            const chunk = _c
            buffer += chunk.toString("utf8")
            while (true) {
              const breakIndex = buffer.search(breakRegex)
              if (breakIndex === -1) break
              const block = buffer.slice(0, breakIndex)
              buffer = buffer.slice(breakIndex + particleBreakSymbol.length)
              await this._transformAndAppendBlockAsync(block)
            }
          } finally {
            _d = true
          }
        }
      } catch (e_1_1) {
        e_1 = { error: e_1_1 }
      } finally {
        try {
          if (!_d && !_a && (_b = input_1.return)) await _b.call(input_1)
        } finally {
          if (e_1) throw e_1.error
        }
      }
      // Process remaining buffer
      await this._transformAndAppendBlockAsync(buffer)
    }
    // Browser ReadableStream
    else if (typeof ReadableStream !== "undefined" && input instanceof ReadableStream) {
      const reader = input.getReader()
      try {
        while (true) {
          const { done, value } = await reader.read()
          if (done) break
          buffer += new TextDecoder().decode(value) // Convert Uint8Array to string
          while (true) {
            const breakIndex = buffer.search(breakRegex)
            if (breakIndex === -1) break
            const block = buffer.slice(0, breakIndex)
            buffer = buffer.slice(breakIndex + particleBreakSymbol.length)
            await this._transformAndAppendBlockAsync(block)
          }
        }
        // Process remaining buffer
        await this._transformAndAppendBlockAsync(buffer)
      } finally {
        reader.releaseLock()
      }