@remotion/streaming
Advanced tools
Comparing version 4.0.187 to 4.0.188
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.makeStreamPayloadMessage = exports.makeStreamer = exports.streamingKey = void 0; | ||
const stream_1 = require("stream"); | ||
exports.streamingKey = 'remotion_buffer:'; | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers = new stream_1.EventEmitter(); | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.setMaxListeners(201); | ||
const makeStreamer = (onMessage) => { | ||
@@ -95,7 +90,2 @@ const separator = new Uint8Array(exports.streamingKey.length); | ||
}; | ||
const dumpBuffers = () => { | ||
console.log('Request with unused data', { missingData, unprocessedBuffers }); | ||
}; | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.addListener('dump-unreleased-buffers', dumpBuffers); | ||
const onData = (data) => { | ||
@@ -127,4 +117,2 @@ unprocessedBuffers.push(data); | ||
outputBuffer = new Uint8Array(0); | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.removeListener('dump-unreleased-buffers', dumpBuffers); | ||
}, | ||
@@ -131,0 +119,0 @@ }; |
@@ -6,3 +6,3 @@ { | ||
"name": "@remotion/streaming", | ||
"version": "4.0.187", | ||
"version": "4.0.188", | ||
"description": "Utilities for streaming data between programs", | ||
@@ -9,0 +9,0 @@ "main": "dist", |
Sorry, the diff of this file is not supported yet
50269
215