MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / ensureNodeStream

Function ensureNodeStream

out/cli.cjs:75689–75696  ·  view source on GitHub ↗
(stream4)

Source from the content-addressed store, hash-verified

75687function makeAsyncIterable(webStream) {
75688 if (!webStream[Symbol.asyncIterator]) {
75689 webStream[Symbol.asyncIterator] = streamAsyncIterator.bind(webStream);
75690 }
75691 if (!webStream.values) {
75692 webStream.values = streamAsyncIterator.bind(webStream);
75693 }
75694}
75695function ensureNodeStream(stream4) {
75696 if (stream4 instanceof ReadableStream) {
75697 makeAsyncIterable(stream4);
75698 return import_node_stream2.Readable.fromWeb(stream4);
75699 } else {

Callers 1

toStreamFunction · 0.85

Calls 1

makeAsyncIterableFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…