Summary
In lib/core/extensions/rpc/json_rpc_stdio_client.dart:
_lines = stdout.transform(
boundedUtf8LineSplitter(maxLineBytes: maxLineBytes),
);
_subscription = _lines.listen(
_onLine,
onError: _onError,
onDone: _onDone,
cancelOnError: false,
);
While boundedUtf8LineSplitter enforces a 32 MB limit per line, it reads the stdout stream eagerly without flow control / backpressure.
If a driver plugin emits a large analytical result set (e.g. tens of thousands of NDJSON lines) faster than the Flutter event loop can process them, decoded strings accumulate rapidly in the stream queue, causing significant memory spikes and risking out-of-memory errors on client machines.
Scope
• Implement stream pause/resume (_subscription.pause() / resume()) when in-flight queue size exceeds a safety threshold.
• Bound the maximum buffered lines awaiting isolate decoding in JsonRpcStdioClient.
• Benchmark memory consumption under simulated heavy NDJSON streaming.
Out of scope
• Changing the underlying stdio transport to shared memory or sockets.
Summary
In
lib/core/extensions/rpc/json_rpc_stdio_client.dart:While
boundedUtf8LineSplitterenforces a 32 MB limit per line, it reads thestdoutstream eagerly without flow control / backpressure.If a driver plugin emits a large analytical result set (e.g. tens of thousands of NDJSON lines) faster than the Flutter event loop can process them, decoded strings accumulate rapidly in the stream queue, causing significant memory spikes and risking out-of-memory errors on client machines.
Scope
• Implement stream pause/resume (
_subscription.pause()/resume()) when in-flight queue size exceeds a safety threshold.• Bound the maximum buffered lines awaiting isolate decoding in
JsonRpcStdioClient.• Benchmark memory consumption under simulated heavy NDJSON streaming.
Out of scope
• Changing the underlying stdio transport to shared memory or sockets.