@remotion/streaming
Advanced tools
Comparing version 4.0.173 to 4.0.174
"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:'; | ||
const magicWordStr = 'remotion_buffer:'; | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers = new stream_1.EventEmitter(); | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.setMaxListeners(201); | ||
const makeStreamer = (onMessage) => { | ||
@@ -77,2 +82,7 @@ const separator = new Uint8Array(magicWordStr.length); | ||
}; | ||
const dumpBuffers = () => { | ||
console.log('Request with unused data', { missingData, unprocessedBuffers }); | ||
}; | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.addListener('dump-unreleased-buffers', dumpBuffers); | ||
const onData = (data) => { | ||
@@ -105,2 +115,4 @@ unprocessedBuffers.push(data); | ||
outputBuffer = new Uint8Array(0); | ||
// @ts-expect-error | ||
globalThis._dumpUnreleasedBuffers.removeListener('dump-unreleased-buffers', dumpBuffers); | ||
}, | ||
@@ -107,0 +119,0 @@ }; |
{ | ||
"name": "@remotion/streaming", | ||
"version": "4.0.173", | ||
"version": "4.0.174", | ||
"description": "Internal streaming helpers", | ||
@@ -5,0 +5,0 @@ "main": "dist", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
48689
215