MCPcopy Create free account
hub / github.com/apache/maka / onPipeData

Method onPipeData

packages/runtime/src/shell-run-manager.ts:981–987  ·  view source on GitHub ↗
(live: LivePipeShellRun, stream: 'stdout' | 'stderr', data: string)

Source from the content-addressed store, hash-verified

979 }
980
981 private onPipeData(live: LivePipeShellRun, stream: 'stdout' | 'stderr', data: string): void {
982 if (live.driverExit || live.finalizeOnce) return;
983 live.collector.accept(stream, data);
984 live.pendingFlushChars += data.length;
985 this.emitLivePipeOutput(live, stream, data);
986 this.scheduleAutomaticFlush(live);
987 }
988
989 private onPtyData(live: LivePtyShellRun, data: string): void {
990 if (live.driverExit || live.finalizeOnce) return;

Callers 1

startPipeMethod · 0.95

Calls 3

emitLivePipeOutputMethod · 0.95
acceptMethod · 0.65

Tested by

no test coverage detected