New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

mediasoup-client

Package Overview
Dependencies
Maintainers
2
Versions
245
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

mediasoup-client - npm Package Compare versions

Comparing version 3.6.68 to 3.6.69

6

lib/Consumer.d.ts

@@ -110,6 +110,6 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

resume(): void;
private _onTrackEnded;
private _handleTrack;
private _destroyTrack;
private onTrackEnded;
private handleTrack;
private destroyTrack;
}
//# sourceMappingURL=Consumer.d.ts.map

@@ -24,4 +24,4 @@ "use strict";

this._appData = appData || {};
this._onTrackEnded = this._onTrackEnded.bind(this);
this._handleTrack();
this.onTrackEnded = this.onTrackEnded.bind(this);
this.handleTrack();
}

@@ -106,3 +106,3 @@ /**

this._closed = true;
this._destroyTrack();
this.destroyTrack();
this.emit('@close');

@@ -120,3 +120,3 @@ // Emit observer event.

this._closed = true;
this._destroyTrack();
this.destroyTrack();
this.safeEmit('transportclose');

@@ -174,3 +174,3 @@ // Emit observer event.

}
_onTrackEnded() {
onTrackEnded() {
logger.debug('track "ended" event');

@@ -181,8 +181,8 @@ this.safeEmit('trackended');

}
_handleTrack() {
this._track.addEventListener('ended', this._onTrackEnded);
handleTrack() {
this._track.addEventListener('ended', this.onTrackEnded);
}
_destroyTrack() {
destroyTrack() {
try {
this._track.removeEventListener('ended', this._onTrackEnded);
this._track.removeEventListener('ended', this.onTrackEnded);
this._track.stop();

@@ -189,0 +189,0 @@ }

@@ -90,4 +90,4 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

transportClosed(): void;
private _handleDataChannel;
private handleDataChannel;
}
//# sourceMappingURL=DataConsumer.d.ts.map

@@ -20,3 +20,3 @@ "use strict";

this._appData = appData || {};
this._handleDataChannel();
this.handleDataChannel();
}

@@ -119,3 +119,3 @@ /**

}
_handleDataChannel() {
handleDataChannel() {
this._dataChannel.addEventListener('open', () => {

@@ -122,0 +122,0 @@ if (this._closed)

@@ -94,4 +94,4 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

send(data: any): void;
private _handleDataChannel;
private handleDataChannel;
}
//# sourceMappingURL=DataProducer.d.ts.map

@@ -20,3 +20,3 @@ "use strict";

this._appData = appData || {};
this._handleDataChannel();
this.handleDataChannel();
}

@@ -130,3 +130,3 @@ /**

}
_handleDataChannel() {
handleDataChannel() {
this._dataChannel.addEventListener('open', () => {

@@ -133,0 +133,0 @@ if (this._closed)

@@ -89,4 +89,4 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

createRecvTransport({ id, iceParameters, iceCandidates, dtlsParameters, sctpParameters, iceServers, iceTransportPolicy, additionalSettings, proprietaryConstraints, appData }: TransportOptions): Transport;
private _createTransport;
private createTransport;
}
//# sourceMappingURL=Device.d.ts.map
"use strict";
/* global RTCRtpTransceiver */
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {

@@ -276,4 +275,5 @@ if (k2 === undefined) k2 = k;

try {
if (this._loaded)
if (this._loaded) {
throw new errors_1.InvalidStateError('already loaded');
}
// This may throw.

@@ -336,3 +336,3 @@ ortc.validateRtpCapabilities(routerRtpCapabilities);

logger.debug('createSendTransport()');
return this._createTransport({
return this.createTransport({
direction: 'send',

@@ -359,3 +359,3 @@ id: id,

logger.debug('createRecvTransport()');
return this._createTransport({
return this.createTransport({
direction: 'recv',

@@ -374,3 +374,3 @@ id: id,

}
_createTransport({ direction, id, iceParameters, iceCandidates, dtlsParameters, sctpParameters, iceServers, iceTransportPolicy, additionalSettings, proprietaryConstraints, appData }) {
createTransport({ direction, id, iceParameters, iceCandidates, dtlsParameters, sctpParameters, iceServers, iceTransportPolicy, additionalSettings, proprietaryConstraints, appData }) {
if (!this._loaded)

@@ -377,0 +377,0 @@ throw new errors_1.InvalidStateError('not loaded');

@@ -47,6 +47,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Chrome55.d.ts.map

@@ -209,3 +209,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -227,3 +227,3 @@ if (codec) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -289,3 +289,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -345,3 +345,3 @@ const track = this._mapSendLocalIdTrack.get(localId);

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -369,3 +369,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -393,3 +393,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -427,3 +427,3 @@ for (const options of optionsList) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -452,3 +452,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -484,3 +484,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -508,3 +508,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -520,3 +520,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -536,3 +536,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -542,3 +542,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -545,0 +545,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -47,6 +47,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Chrome67.d.ts.map

@@ -208,3 +208,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -226,3 +226,3 @@ if (codec) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -292,3 +292,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -331,3 +331,3 @@ const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -352,3 +352,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -368,3 +368,3 @@ const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -381,3 +381,3 @@ const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

@@ -390,3 +390,3 @@ if (!rtpSender)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -414,3 +414,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -438,3 +438,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -472,3 +472,3 @@ for (const options of optionsList) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -499,3 +499,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -526,3 +526,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const { rtpReceiver } = this._mapRecvLocalIdInfo.get(localId) || {};

@@ -535,3 +535,3 @@ if (!rtpReceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -559,3 +559,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -571,3 +571,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -587,3 +587,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -593,3 +593,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -596,0 +596,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -45,6 +45,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Chrome70.d.ts.map

@@ -202,3 +202,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -219,3 +219,3 @@ const sendingRtpParameters = utils.clone(this._sendingRtpParametersByKind[track.kind], {});

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -319,3 +319,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -351,3 +351,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -365,3 +365,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -381,3 +381,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -394,3 +394,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -403,3 +403,3 @@ if (!transceiver)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -427,3 +427,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -451,3 +451,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -487,3 +487,3 @@ const mapLocalId = new Map();

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -513,3 +513,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -543,3 +543,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -552,3 +552,3 @@ if (!transceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -576,3 +576,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -588,3 +588,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -604,3 +604,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -610,3 +610,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -613,0 +613,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -45,6 +45,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Chrome74.d.ts.map

@@ -202,3 +202,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -228,3 +228,3 @@ if (encodings && encodings.length > 1) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -310,3 +310,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -334,3 +334,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async pauseSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('pauseSending() [localId:%s]', localId);

@@ -350,3 +350,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async resumeSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('resumeSending() [localId:%s]', localId);

@@ -366,3 +366,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -380,3 +380,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -396,3 +396,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -409,3 +409,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -418,3 +418,3 @@ if (!transceiver)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -441,3 +441,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -465,3 +465,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -501,3 +501,3 @@ const mapLocalId = new Map();

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -530,3 +530,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -550,3 +550,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async pauseReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -568,3 +568,3 @@ logger.debug('pauseReceiving() [localId:%s]', localId);

async resumeReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -586,3 +586,3 @@ logger.debug('resumeReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -595,3 +595,3 @@ if (!transceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -618,3 +618,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -630,3 +630,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -646,3 +646,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -652,3 +652,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -655,0 +655,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -50,7 +50,7 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel(options: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setIceGatherer;
private _setIceTransport;
private _setDtlsTransport;
private _setupTransport;
private setIceGatherer;
private setIceTransport;
private setDtlsTransport;
private setupTransport;
}
//# sourceMappingURL=Edge11.d.ts.map

@@ -114,5 +114,5 @@ "use strict";

this._cname = `CNAME-${utils.generateRandomNumber()}`;
this._setIceGatherer({ iceServers, iceTransportPolicy });
this._setIceTransport();
this._setDtlsTransport();
this.setIceGatherer({ iceServers, iceTransportPolicy });
this.setIceTransport();
this.setDtlsTransport();
}

@@ -144,3 +144,3 @@ // eslint-disable-next-line @typescript-eslint/no-unused-vars

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'server' });
await this.setupTransport({ localDtlsRole: 'server' });
logger.debug('send() | calling new RTCRtpSender()');

@@ -257,3 +257,3 @@ const rtpSender = new RTCRtpSender(track, this._dtlsTransport);

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'server' });
await this.setupTransport({ localDtlsRole: 'server' });
for (const options of optionsList) {

@@ -319,3 +319,3 @@ const { trackId, kind, rtpParameters } = options;

}
_setIceGatherer({ iceServers, iceTransportPolicy }) {
setIceGatherer({ iceServers, iceTransportPolicy }) {
// @ts-ignore

@@ -334,7 +334,7 @@ const iceGatherer = new RTCIceGatherer({

catch (error) {
logger.debug('_setIceGatherer() | iceGatherer.gather() failed: %s', error.toString());
logger.debug('setIceGatherer() | iceGatherer.gather() failed: %s', error.toString());
}
this._iceGatherer = iceGatherer;
}
_setIceTransport() {
setIceTransport() {
const iceTransport = new RTCIceTransport(this._iceGatherer);

@@ -388,3 +388,3 @@ // NOTE: Not yet implemented by Edge.

}
_setDtlsTransport() {
setDtlsTransport() {
const dtlsTransport = new RTCDtlsTransport(this._iceTransport);

@@ -406,4 +406,4 @@ // NOTE: Not yet implemented by Edge.

}
async _setupTransport({ localDtlsRole }) {
logger.debug('_setupTransport()');
async setupTransport({ localDtlsRole }) {
logger.debug('setupTransport()');
// Get our local DTLS parameters.

@@ -410,0 +410,0 @@ const dtlsParameters = this._dtlsTransport.getLocalParameters();

@@ -47,4 +47,4 @@ import { HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private setupTransport;
}
//# sourceMappingURL=FakeHandler.d.ts.map

@@ -126,3 +126,3 @@ "use strict";

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'server' });
await this.setupTransport({ localDtlsRole: 'server' });
const rtpParameters = utils.clone(this._rtpParametersByKind[track.kind], {});

@@ -187,3 +187,3 @@ const useRtx = rtpParameters.codecs

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'server' });
await this.setupTransport({ localDtlsRole: 'server' });
logger.debug('sendDataChannel()');

@@ -212,3 +212,3 @@ const dataChannel = new FakeDataChannel({

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'client' });
await this.setupTransport({ localDtlsRole: 'client' });
logger.debug('receive() [trackId:%s, kind:%s]', trackId, kind);

@@ -244,3 +244,3 @@ const localId = this._nextLocalId++;

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'client' });
await this.setupTransport({ localDtlsRole: 'client' });
logger.debug('receiveDataChannel()');

@@ -258,3 +258,3 @@ const dataChannel = new FakeDataChannel({

}
async _setupTransport({ localDtlsRole,
async setupTransport({ localDtlsRole,
// eslint-disable-next-line @typescript-eslint/no-unused-vars

@@ -261,0 +261,0 @@ localSdpObject }) {

@@ -44,6 +44,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Firefox60.d.ts.map

@@ -222,3 +222,3 @@ "use strict";

async send({ track, encodings, codecOptions, codec }) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -262,3 +262,3 @@ if (encodings) {

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'client', localSdpObject });
await this.setupTransport({ localDtlsRole: 'client', localSdpObject });
logger.debug('send() | calling pc.setLocalDescription() [offer:%o]', offer);

@@ -348,3 +348,3 @@ await this._pc.setLocalDescription(offer);

async pauseSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('pauseSending() [localId:%s]', localId);

@@ -365,3 +365,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async resumeSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('resumeSending() [localId:%s]', localId);

@@ -381,3 +381,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -395,3 +395,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -414,3 +414,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -427,3 +427,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -435,3 +435,3 @@ if (!transceiver)

async sendDataChannel({ ordered, maxPacketLifeTime, maxRetransmits, label, protocol }) {
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -458,3 +458,3 @@ negotiated: true,

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'client', localSdpObject });
await this.setupTransport({ localDtlsRole: 'client', localSdpObject });
logger.debug('sendDataChannel() | calling pc.setLocalDescription() [offer:%o]', offer);

@@ -479,3 +479,3 @@ await this._pc.setLocalDescription(offer);

optionsList) {
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -515,3 +515,3 @@ const mapLocalId = new Map();

if (!this._transportReady)
await this._setupTransport({ localDtlsRole: 'client', localSdpObject });
await this.setupTransport({ localDtlsRole: 'client', localSdpObject });
logger.debug('receive() | calling pc.setLocalDescription() [answer:%o]', answer);

@@ -537,3 +537,3 @@ await this._pc.setLocalDescription(answer);

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -557,3 +557,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async pauseReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -575,3 +575,3 @@ logger.debug('pauseReceiving() [localId:%s]', localId);

async resumeReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -593,3 +593,3 @@ logger.debug('resumeReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -601,3 +601,3 @@ if (!transceiver)

async receiveDataChannel({ sctpStreamParameters, label, protocol }) {
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -624,3 +624,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({ localDtlsRole: 'client', localSdpObject });
await this.setupTransport({ localDtlsRole: 'client', localSdpObject });
}

@@ -633,3 +633,3 @@ logger.debug('receiveDataChannel() | calling pc.setRemoteDescription() [answer:%o]', answer);

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -649,3 +649,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -655,3 +655,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -658,0 +658,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -47,6 +47,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=ReactNative.d.ts.map

@@ -213,3 +213,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -231,3 +231,3 @@ if (codec) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -295,3 +295,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -351,3 +351,3 @@ const track = this._mapSendLocalIdTrack.get(localId);

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -375,3 +375,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -399,3 +399,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -443,3 +443,3 @@ const mapStreamId = new Map();

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -468,3 +468,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -500,3 +500,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -524,3 +524,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -536,3 +536,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -552,3 +552,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -558,3 +558,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -561,0 +561,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -45,6 +45,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=ReactNativeUnifiedPlan.d.ts.map

@@ -206,3 +206,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -232,3 +232,3 @@ if (encodings && encodings.length > 1) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -314,3 +314,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -338,3 +338,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async pauseSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('pauseSending() [localId:%s]', localId);

@@ -354,3 +354,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async resumeSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('resumeSending() [localId:%s]', localId);

@@ -370,3 +370,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -384,3 +384,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -400,3 +400,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -413,3 +413,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -422,3 +422,3 @@ if (!transceiver)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -445,3 +445,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -469,3 +469,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -505,3 +505,3 @@ const mapLocalId = new Map();

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -534,3 +534,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -554,3 +554,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async pauseReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -572,3 +572,3 @@ logger.debug('pauseReceiving() [localId:%s]', localId);

async resumeReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -590,3 +590,3 @@ logger.debug('resumeReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -599,3 +599,3 @@ if (!transceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -622,3 +622,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -634,3 +634,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -650,3 +650,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -656,3 +656,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -659,0 +659,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -47,6 +47,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Safari11.d.ts.map

@@ -207,3 +207,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -225,3 +225,3 @@ if (codec) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -290,3 +290,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

@@ -327,3 +327,3 @@ if (!rtpSender)

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -348,3 +348,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -364,3 +364,3 @@ const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -377,3 +377,3 @@ const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const rtpSender = this._mapSendLocalIdRtpSender.get(localId);

@@ -386,3 +386,3 @@ if (!rtpSender)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -409,3 +409,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -433,3 +433,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -467,3 +467,3 @@ for (const options of optionsList) {

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -494,3 +494,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -511,3 +511,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const { rtpReceiver } = this._mapRecvLocalIdInfo.get(localId) || {};

@@ -530,3 +530,3 @@ if (!rtpReceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -553,3 +553,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -565,3 +565,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -581,3 +581,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -587,3 +587,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -590,0 +590,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -45,6 +45,6 @@ import { HandlerFactory, HandlerInterface, HandlerRunOptions, HandlerSendOptions, HandlerSendResult, HandlerReceiveOptions, HandlerReceiveResult, HandlerSendDataChannelOptions, HandlerSendDataChannelResult, HandlerReceiveDataChannelOptions, HandlerReceiveDataChannelResult } from './HandlerInterface';

receiveDataChannel({ sctpStreamParameters, label, protocol }: HandlerReceiveDataChannelOptions): Promise<HandlerReceiveDataChannelResult>;
private _setupTransport;
private _assertSendDirection;
private _assertRecvDirection;
private setupTransport;
private assertSendDirection;
private assertRecvDirection;
}
//# sourceMappingURL=Safari12.d.ts.map

@@ -199,3 +199,3 @@ "use strict";

var _a;
this._assertSendDirection();
this.assertSendDirection();
logger.debug('send() [kind:%s, track.id:%s]', track.kind, track.id);

@@ -216,3 +216,3 @@ const sendingRtpParameters = utils.clone(this._sendingRtpParametersByKind[track.kind], {});

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -281,3 +281,3 @@ localSdpObject

async stopSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('stopSending() [localId:%s]', localId);

@@ -306,3 +306,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async pauseSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('pauseSending() [localId:%s]', localId);

@@ -323,3 +323,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async resumeSending(localId) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('resumeSending() [localId:%s]', localId);

@@ -339,3 +339,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async replaceTrack(localId, track) {
this._assertSendDirection();
this.assertSendDirection();
if (track) {

@@ -353,3 +353,3 @@ logger.debug('replaceTrack() [localId:%s, track.id:%s]', localId, track.id);

async setMaxSpatialLayer(localId, spatialLayer) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setMaxSpatialLayer() [localId:%s, spatialLayer:%s]', localId, spatialLayer);

@@ -369,3 +369,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async setRtpEncodingParameters(localId, params) {
this._assertSendDirection();
this.assertSendDirection();
logger.debug('setRtpEncodingParameters() [localId:%s, params:%o]', localId, params);

@@ -382,3 +382,3 @@ const transceiver = this._mapMidTransceiver.get(localId);

async getSenderStats(localId) {
this._assertSendDirection();
this.assertSendDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -391,3 +391,3 @@ if (!transceiver)

var _a;
this._assertSendDirection();
this.assertSendDirection();
const options = {

@@ -414,3 +414,3 @@ negotiated: true,

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -438,3 +438,3 @@ localSdpObject

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const results = [];

@@ -474,3 +474,3 @@ const mapLocalId = new Map();

if (!this._transportReady) {
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -500,3 +500,3 @@ localSdpObject

async stopReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -520,3 +520,3 @@ logger.debug('stopReceiving() [localId:%s]', localId);

async pauseReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -538,3 +538,3 @@ logger.debug('pauseReceiving() [localId:%s]', localId);

async resumeReceiving(localIds) {
this._assertRecvDirection();
this.assertRecvDirection();
for (const localId of localIds) {

@@ -556,3 +556,3 @@ logger.debug('resumeReceiving() [localId:%s]', localId);

async getReceiverStats(localId) {
this._assertRecvDirection();
this.assertRecvDirection();
const transceiver = this._mapMidTransceiver.get(localId);

@@ -565,3 +565,3 @@ if (!transceiver)

var _a;
this._assertRecvDirection();
this.assertRecvDirection();
const { streamId, ordered, maxPacketLifeTime, maxRetransmits } = sctpStreamParameters;

@@ -588,3 +588,3 @@ const options = {

const localSdpObject = sdpTransform.parse(answer.sdp);
await this._setupTransport({
await this.setupTransport({
localDtlsRole: (_a = this._forcedLocalDtlsRole) !== null && _a !== void 0 ? _a : 'client',

@@ -600,3 +600,3 @@ localSdpObject

}
async _setupTransport({ localDtlsRole, localSdpObject }) {
async setupTransport({ localDtlsRole, localSdpObject }) {
if (!localSdpObject)

@@ -616,3 +616,3 @@ localSdpObject = sdpTransform.parse(this._pc.localDescription.sdp);

}
_assertSendDirection() {
assertSendDirection() {
if (this._direction !== 'send') {

@@ -622,3 +622,3 @@ throw new Error('method can just be called for handlers with "send" direction');

}
_assertRecvDirection() {
assertRecvDirection() {
if (this._direction !== 'recv') {

@@ -625,0 +625,0 @@ throw new Error('method can just be called for handlers with "recv" direction');

@@ -11,3 +11,3 @@ import debug from 'debug';

*/
export declare const version = "3.6.68";
export declare const version = "3.6.69";
/**

@@ -14,0 +14,0 @@ * Expose Device class and detectDevice() helper.

@@ -40,3 +40,3 @@ "use strict";

*/
exports.version = '3.6.68';
exports.version = '3.6.69';
/**

@@ -43,0 +43,0 @@ * Expose parseScalabilityMode() function.

@@ -163,6 +163,6 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

setRtpEncodingParameters(params: RTCRtpEncodingParameters): Promise<void>;
private _onTrackEnded;
private _handleTrack;
private _destroyTrack;
private onTrackEnded;
private handleTrack;
private destroyTrack;
}
//# sourceMappingURL=Producer.d.ts.map

@@ -28,6 +28,6 @@ "use strict";

this._appData = appData || {};
this._onTrackEnded = this._onTrackEnded.bind(this);
this.onTrackEnded = this.onTrackEnded.bind(this);
// NOTE: Minor issue. If zeroRtpOnPause is true, we cannot emit the
// '@replacetrack' event here, so RTCRtpSender.track won't be null.
this._handleTrack();
this.handleTrack();
}

@@ -114,3 +114,3 @@ /**

this._closed = true;
this._destroyTrack();
this.destroyTrack();
this.emit('@close');

@@ -128,3 +128,3 @@ // Emit observer event.

this._closed = true;
this._destroyTrack();
this.destroyTrack();
this.safeEmit('transportclose');

@@ -214,3 +214,3 @@ // Emit observer event.

// Destroy the previous track.
this._destroyTrack();
this.destroyTrack();
// Set the new track.

@@ -227,3 +227,3 @@ this._track = track;

// Handle the effective track.
this._handleTrack();
this.handleTrack();
}

@@ -256,3 +256,3 @@ /**

}
_onTrackEnded() {
onTrackEnded() {
logger.debug('track "ended" event');

@@ -263,12 +263,12 @@ this.safeEmit('trackended');

}
_handleTrack() {
handleTrack() {
if (!this._track)
return;
this._track.addEventListener('ended', this._onTrackEnded);
this._track.addEventListener('ended', this.onTrackEnded);
}
_destroyTrack() {
destroyTrack() {
if (!this._track)
return;
try {
this._track.removeEventListener('ended', this._onTrackEnded);
this._track.removeEventListener('ended', this.onTrackEnded);
// Just stop the track unless the app set stopTracks: false.

@@ -275,0 +275,0 @@ if (this._stopTracks)

@@ -233,13 +233,13 @@ import { EnhancedEventEmitter } from './EnhancedEventEmitter';

consumeData({ id, dataProducerId, sctpStreamParameters, label, protocol, appData }: DataConsumerOptions): Promise<DataConsumer>;
_createPendingConsumers(): Promise<void>;
_pausePendingConsumers(): void;
_resumePendingConsumers(): void;
_closePendingConsumers(): void;
_handleHandler(): void;
_handleProducer(producer: Producer): void;
_handleConsumer(consumer: Consumer): void;
_handleDataProducer(dataProducer: DataProducer): void;
_handleDataConsumer(dataConsumer: DataConsumer): void;
private createPendingConsumers;
private pausePendingConsumers;
private resumePendingConsumers;
private closePendingConsumers;
private handleHandler;
private handleProducer;
private handleConsumer;
private handleDataProducer;
private handleDataConsumer;
}
export {};
//# sourceMappingURL=Transport.d.ts.map

@@ -65,3 +65,3 @@ "use strict";

// AwaitQueue instance to make async tasks happen sequentially.
this._awaitQueue = new awaitqueue_1.AwaitQueue({ ClosedErrorClass: errors_1.InvalidStateError });
this._awaitQueue = new awaitqueue_1.AwaitQueue();
// Consumer creation tasks awaiting to be processed.

@@ -113,3 +113,3 @@ this._pendingConsumerTasks = [];

this._appData = appData || {};
this._handleHandler();
this.handleHandler();
}

@@ -170,4 +170,4 @@ /**

this._closed = true;
// Close the AwaitQueue.
this._awaitQueue.close();
// Stop the AwaitQueue.
this._awaitQueue.stop();
// Close the handler.

@@ -237,3 +237,5 @@ this._handler.close();

logger.debug('produce() [track:%o]', track);
if (!track)
if (this._closed)
throw new errors_1.InvalidStateError('closed');
else if (!track)
throw new TypeError('missing track');

@@ -314,3 +316,3 @@ else if (this._direction !== 'send')

this._producers.set(producer.id, producer);
this._handleProducer(producer);
this.handleProducer(producer);
// Emit observer event.

@@ -374,3 +376,3 @@ this._observer.safeEmit('newproducer', producer);

if (this._consumerCreationInProgress === false) {
this._createPendingConsumers();
this.createPendingConsumers();
}

@@ -384,3 +386,5 @@ return consumerCreationTask.promise;

logger.debug('produceData()');
if (this._direction !== 'send')
if (this._closed)
throw new errors_1.InvalidStateError('closed');
else if (this._direction !== 'send')
throw new errors_1.UnsupportedError('not a sending Transport');

@@ -418,3 +422,3 @@ else if (!this._maxSctpMessageSize)

this._dataProducers.set(dataProducer.id, dataProducer);
this._handleDataProducer(dataProducer);
this.handleDataProducer(dataProducer);
// Emit observer event.

@@ -462,3 +466,3 @@ this._observer.safeEmit('newdataproducer', dataProducer);

this._dataConsumers.set(dataConsumer.id, dataConsumer);
this._handleDataConsumer(dataConsumer);
this.handleDataConsumer(dataConsumer);
// Emit observer event.

@@ -470,7 +474,7 @@ this._observer.safeEmit('newdataconsumer', dataConsumer);

// This method is guaranteed to never throw.
async _createPendingConsumers() {
async createPendingConsumers() {
this._consumerCreationInProgress = true;
this._awaitQueue.push(async () => {
if (this._pendingConsumerTasks.length === 0) {
logger.debug('_createPendingConsumers() | there is no Consumer to be created');
logger.debug('createPendingConsumers() | there is no Consumer to be created');
return;

@@ -511,3 +515,3 @@ }

this._consumers.set(consumer.id, consumer);
this._handleConsumer(consumer);
this.handleConsumer(consumer);
// If this is the first video Consumer and the Consumer for RTP probation

@@ -537,10 +541,10 @@ // has not yet been created, it's time to create it.

}]);
logger.debug('_createPendingConsumers() | Consumer for RTP probation created');
logger.debug('createPendingConsumers() | Consumer for RTP probation created');
this._probatorConsumerCreated = true;
}
catch (error) {
logger.error('_createPendingConsumers() | failed to create Consumer for RTP probation:%o', error);
logger.error('createPendingConsumers() | failed to create Consumer for RTP probation:%o', error);
}
}
}, 'transport._createPendingConsumers()')
}, 'transport.createPendingConsumers()')
.then(() => {

@@ -550,3 +554,3 @@ this._consumerCreationInProgress = false;

if (this._pendingConsumerTasks.length > 0) {
this._createPendingConsumers();
this.createPendingConsumers();
}

@@ -557,7 +561,7 @@ })

}
_pausePendingConsumers() {
pausePendingConsumers() {
this._consumerPauseInProgress = true;
this._awaitQueue.push(async () => {
if (this._pendingPauseConsumers.size === 0) {
logger.debug('_pausePendingConsumers() | there is no Consumer to be paused');
logger.debug('pausePendingConsumers() | there is no Consumer to be paused');
return;

@@ -574,5 +578,5 @@ }

catch (error) {
logger.error('_pausePendingConsumers() | failed to pause Consumers:', error);
logger.error('pausePendingConsumers() | failed to pause Consumers:', error);
}
}, 'transport._pausePendingConsumers')
}, 'transport.pausePendingConsumers')
.then(() => {

@@ -582,3 +586,3 @@ this._consumerPauseInProgress = false;

if (this._pendingPauseConsumers.size > 0) {
this._pausePendingConsumers();
this.pausePendingConsumers();
}

@@ -589,7 +593,7 @@ })

}
_resumePendingConsumers() {
resumePendingConsumers() {
this._consumerResumeInProgress = true;
this._awaitQueue.push(async () => {
if (this._pendingResumeConsumers.size === 0) {
logger.debug('_resumePendingConsumers() | there is no Consumer to be resumed');
logger.debug('resumePendingConsumers() | there is no Consumer to be resumed');
return;

@@ -606,5 +610,5 @@ }

catch (error) {
logger.error('_resumePendingConsumers() | failed to resume Consumers:', error);
logger.error('resumePendingConsumers() | failed to resume Consumers:', error);
}
}, 'transport._resumePendingConsumers')
}, 'transport.resumePendingConsumers')
.then(() => {

@@ -614,3 +618,3 @@ this._consumerResumeInProgress = false;

if (this._pendingResumeConsumers.size > 0) {
this._resumePendingConsumers();
this.resumePendingConsumers();
}

@@ -621,7 +625,7 @@ })

}
_closePendingConsumers() {
closePendingConsumers() {
this._consumerCloseInProgress = true;
this._awaitQueue.push(async () => {
if (this._pendingCloseConsumers.size === 0) {
logger.debug('_closePendingConsumers() | there is no Consumer to be closed');
logger.debug('closePendingConsumers() | there is no Consumer to be closed');
return;

@@ -636,5 +640,5 @@ }

catch (error) {
logger.error('_closePendingConsumers() | failed to close Consumers:', error);
logger.error('closePendingConsumers() | failed to close Consumers:', error);
}
}, 'transport._closePendingConsumers')
}, 'transport.closePendingConsumers')
.then(() => {

@@ -644,3 +648,3 @@ this._consumerCloseInProgress = false;

if (this._pendingCloseConsumers.size > 0) {
this._closePendingConsumers();
this.closePendingConsumers();
}

@@ -651,3 +655,3 @@ })

}
_handleHandler() {
handleHandler() {
const handler = this._handler;

@@ -670,3 +674,3 @@ handler.on('@connect', ({ dtlsParameters }, callback, errback) => {

}
_handleProducer(producer) {
handleProducer(producer) {
producer.on('@close', () => {

@@ -712,3 +716,3 @@ this._producers.delete(producer.id);

}
_handleConsumer(consumer) {
handleConsumer(consumer) {
consumer.on('@close', () => {

@@ -724,3 +728,3 @@ this._consumers.delete(consumer.id);

if (this._consumerCloseInProgress === false) {
this._closePendingConsumers();
this.closePendingConsumers();
}

@@ -737,3 +741,3 @@ });

if (this._consumerPauseInProgress === false) {
this._pausePendingConsumers();
this.pausePendingConsumers();
}

@@ -750,3 +754,3 @@ });

if (this._consumerResumeInProgress === false) {
this._resumePendingConsumers();
this.resumePendingConsumers();
}

@@ -762,3 +766,3 @@ });

}
_handleDataProducer(dataProducer) {
handleDataProducer(dataProducer) {
dataProducer.on('@close', () => {

@@ -768,3 +772,3 @@ this._dataProducers.delete(dataProducer.id);

}
_handleDataConsumer(dataConsumer) {
handleDataConsumer(dataConsumer) {
dataConsumer.on('@close', () => {

@@ -771,0 +775,0 @@ this._dataConsumers.delete(dataConsumer.id);

@@ -49,3 +49,3 @@ /* eslint-disable no-console */

const TscWatchClient = require('tsc-watch/client');
const { TscWatchClient } = require('tsc-watch/client');
const watch = new TscWatchClient();

@@ -52,0 +52,0 @@

{
"name": "mediasoup-client",
"version": "3.6.68",
"version": "3.6.69",
"description": "mediasoup client side JavaScript library",

@@ -65,3 +65,3 @@ "contributors": [

"@types/debug": "^4.1.7",
"awaitqueue": "^2.4.0",
"awaitqueue": "^3.0.0",
"bowser": "^2.11.0",

@@ -73,3 +73,3 @@ "debug": "^4.3.4",

"sdp-transform": "^2.14.1",
"supports-color": "^9.3.0",
"supports-color": "^9.3.1",
"uuid": "^3.4.0"

@@ -82,12 +82,12 @@ },

"@types/uuid": "^3.4.9",
"@typescript-eslint/eslint-plugin": "^5.46.0",
"@typescript-eslint/parser": "^5.46.0",
"eslint": "^8.29.0",
"eslint-plugin-jest": "^27.1.6",
"@typescript-eslint/eslint-plugin": "^5.47.1",
"@typescript-eslint/parser": "^5.47.1",
"eslint": "^8.30.0",
"eslint-plugin-jest": "^27.1.7",
"jest": "^29.3.1",
"open-cli": "^7.1.0",
"ts-jest": "^29.0.3",
"tsc-watch": "^5.0.3",
"tsc-watch": "^6.0.0",
"typescript": "^4.9.4"
}
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc