MCPcopy
hub / github.com/Effect-TS/effect / stream

Function stream

packages/platform/src/internal/commandExecutor.ts:29–30  ·  view source on GitHub ↗
(command)

Source from the content-addressed store, hash-verified

27/** @internal */
28export const makeExecutor = (start: _CommandExecutor.CommandExecutor["start"]): _CommandExecutor.CommandExecutor => {
29 const stream: _CommandExecutor.CommandExecutor["stream"] = (command) =>
30 Stream.unwrapScoped(Effect.map(start(command), (process) => process.stdout))
31 const streamLines: _CommandExecutor.CommandExecutor["streamLines"] = (command, encoding) => {
32 const decoder = new TextDecoder(encoding)
33 return Stream.splitLines(

Callers 1

streamLinesFunction · 0.70

Calls 2

startFunction · 0.70
mapMethod · 0.65

Tested by

no test coverage detected