Skip to content

createMessageSink

createMessageSink<TData>(post, options?): ISink<TData>

Defined in: packages/app-report/src/sink/message-sink.ts:19

Portable IPC sink: serializes each event and hands it to post — the primitive @ac-kit/app-system’s forkProcess/worker transports build on.

flush/close are no-ops: delivery and backpressure are post’s responsibility, not this sink’s.

TData

(message) => void

MessageSinkOptions

ISink<TData>