executeStreaming method

Future<int> executeStreaming({ required String nodeId, required String command, List<String> args = const [], Map<String, String> env = const {}, String? cwd, required void onStdout(List<int> chunk), required void onStderr(List<int> chunk), })

Runs command on nodeId and forwards its output live: each stdout/stderr chunk is delivered to onStdout/onStderr as it arrives, rather than being buffered until the command exits. Returns the process exit code.

Use this for long-running commands where progress should appear in real time; execute is the buffered variant built on top of this.

Implementation

Future<int> executeStreaming({
  required String nodeId,
  required String command,
  List<String> args = const [],
  Map<String, String> env = const {},
  String? cwd,
  required void Function(List<int> chunk) onStdout,
  required void Function(List<int> chunk) onStderr,
}) async {
  final session = await openSession(
    nodeId: nodeId,
    mode: SessionMode.exec,
    command: command,
    args: args,
    env: env,
    cwd: cwd,
  );
  final outDone = session.stdout.forEach(onStdout);
  final errDone = session.stderr.forEach(onStderr);
  final code = await session.exitCode;
  await Future.wait([outDone, errDone]).catchError((_) => const <void>[]);
  return code;
}