Writing to stdin of a running Process using @effect/platform CommandExecutor

How to continuously pipe to

stdin

stdin

of a running

Process

Process

?

In Node.js, we can simply do:

import { spawn } from 'node:child_process';
const ls = spawn('ls', ['-lh', '/usr']);
ls.stdin.write('WRITE DATA')

import { spawn } from 'node:child_process';
const ls = spawn('ls', ['-lh', '/usr']);
ls.stdin.write('WRITE DATA')

But I can't figure out how to do it using

@effect/platform/CommandExecutor

@effect/platform/CommandExecutor

Process

Process

implementation.

stdin

stdin

is a

Sink<void, Uint8Array, never, PlatformError, never>

Sink<void, Uint8Array, never, PlatformError, never>

, but idk how to write to a

Sink

Sink

without having access to the underlying

Stream

Stream

How to continuously pipe to

stdin

stdin

of a running

Process

Process

?

In Node.js, we can simply do:

import { spawn } from 'node:child_process';
const ls = spawn('ls', ['-lh', '/usr']);
ls.stdin.write('WRITE DATA')

import { spawn } from 'node:child_process';
const ls = spawn('ls', ['-lh', '/usr']);
ls.stdin.write('WRITE DATA')

But I can't figure out how to do it using

@effect/platform/CommandExecutor

@effect/platform/CommandExecutor

Process

Process

implementation.

stdin

stdin

is a

Sink<void, Uint8Array, never, PlatformError, never>

Sink<void, Uint8Array, never, PlatformError, never>

, but idk how to write to a

Sink

Sink

without having access to the underlying

Stream

Stream