Method _drain

src/cascade-native-bridge.js:1222–1260

(flush)

  }

  _drain(flush) {
    const out = [];
    const toolCalls = [];
    const openRe = /<function_calls\b/i;
    while (this.buffer) {
      const open = this.buffer.search(openRe);
      if (open === -1) {
        const hold = partialFunctionCallsPrefixLength(this.buffer);
        if (!flush && hold > 0) {
          out.push(this.buffer.slice(0, this.buffer.length - hold));
          this.buffer = this.buffer.slice(this.buffer.length - hold);
          break;
        }
        out.push(this.buffer);
        this.buffer = '';
        break;
      }

      out.push(this.buffer.slice(0, open));
      const tail = this.buffer.slice(open);
      const closeMatch = tail.match(/<\/function_calls>/i);
      if (!closeMatch) {
        if (flush) {
          this.buffer = '';
        } else {
          this.buffer = tail;
        }
        break;
      }

      const end = open + closeMatch.index + closeMatch[0].length;
      const block = this.buffer.slice(open, end);
      const parsed = parseNativeFunctionCallsFromText(block, this.callerLookup);
      out.push(parsed.text || '');
      toolCalls.push(...(parsed.toolCalls || []));
      this.buffer = this.buffer.slice(end);
    }
    return { text: out.join(''), toolCalls };
  }
}

function partialFunctionCallsPrefixLength(text) {