@observertc/observer-js - npm Package Compare versions

Comparing version 0.9.8-beta to 0.9.9-beta

lib/index.d.ts

@@ -5,3 +5,3 @@ export type { ObserverConfig } from './Observer';
 export { Observer } from './Observer';
-export type { ObserverSinkEmitter as ObserverSink } from './sinks/ObserverSink';
+export type { ObserverReportsEmitter, ObserverSinkProcess } from './sinks/ObserverSink';
 export type { ObserverStorage } from './storages/ObserverStorage';
@@ -8,0 +8,0 @@ export type { StorageProvider } from './storages/StorageProvider';

lib/Observer.d.ts

@@ -1,2 +0,2 @@
-import { ObserverSinkEmitter, ObserverSinkProcess, SinkConfig } from './sinks/ObserverSink';
+import { ObserverReportsEmitter, ObserverSinkProcess, SinkConfig } from './sinks/ObserverSink';
 import { SourcesConfig } from './sources/Sources';
@@ -50,3 +50,3 @@ import { StorageProvider } from './storages/StorageProvider';
     createSfuSource(config: PartialBy<ObservedSfuSourceConfig, 'serviceId' | 'mediaUnitId' | 'joined'>): ObservedSfuSource;
-    get sink(): ObserverSinkEmitter;
+    get reports(): ObserverReportsEmitter;
     addEvaluators(...processes: EvaluatorProcess[]): void;
@@ -53,0 +53,0 @@ removeEvaluators(...processes: EvaluatorProcess[]): void;

lib/Observer.js

@@ -125,3 +125,3 @@ "use strict";
     }
-    get sink() {
+    get reports() {
         return this._sink;
@@ -128,0 +128,0 @@ }

lib/sinks/ObserverSink.d.ts

@@ -62,3 +62,3 @@ import { CallEventReport, CallMetaReport, ClientDataChannelReport, ClientExtensionReport, IceCandidatePairReport, InboundAudioTrackReport, InboundVideoTrackReport, ObserverEventReport, OutboundAudioTrackReport, OutboundVideoTrackReport, PeerConnectionTransportReport, SfuEventReport, SfuExtensionReport, SfuInboundRtpPadReport, SfuMetaReport, SfuOutboundRtpPadReport, SfuSctpStreamReport, SFUTransportReport } from '@observertc/report-schemas-js';
 export type ObserverSinkProcess = (observerSinkContext: ObserverSinkContext) => Promise<void>;
-export interface ObserverSinkEmitter {
+export interface ObserverReportsEmitter {
     on<K extends keyof SinkEventsMap>(event: K, listener: (reports: SinkEventsMap[K]) => void): this;
@@ -68,3 +68,3 @@ off<K extends keyof SinkEventsMap>(event: K, listener: (reports: SinkEventsMap[K]) => void): this;
 }
-export declare class SinkImpl implements ReportsCollector, ObserverSinkEmitter {
+export declare class SinkImpl implements ReportsCollector, ObserverReportsEmitter {
     readonly config: SinkConfig;
@@ -71,0 +71,0 @@ private _index;

package.json

 {
   "name": "@observertc/observer-js",
-  "version": "0.9.8-beta",
+  "version": "0.9.9-beta",
   "description": "Server Side NodeJS Library for processing ObserveRTC Samples",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/index.ts

@@ -8,3 +8,3 @@ export type { ObserverConfig } from './Observer';
 export { Observer } from './Observer';
-export type { ObserverSinkEmitter as ObserverSink } from './sinks/ObserverSink';
+export type { ObserverReportsEmitter, ObserverSinkProcess } from './sinks/ObserverSink';
 export type { ObserverStorage } from './storages/ObserverStorage';
@@ -11,0 +11,0 @@ export type { StorageProvider } from './storages/StorageProvider';

src/Observer.ts

@@ -1,2 +0,2 @@
-import { ObserverSinkEmitter, ObserverSinkProcess, SinkConfig, SinkImpl } from './sinks/ObserverSink';
+import { ObserverReportsEmitter, ObserverSinkProcess, SinkConfig, SinkImpl } from './sinks/ObserverSink';
 import { Sources, SourcesConfig } from './sources/Sources';
@@ -175,3 +175,3 @@ import { createSimpleStorageProvider, StorageProvider } from './storages/StorageProvider';
 
-	public get sink(): ObserverSinkEmitter {
+	public get reports(): ObserverReportsEmitter {
 		return this._sink;
@@ -178,0 +178,0 @@ }

src/sinks/ObserverSink.ts

@@ -88,3 +88,3 @@ import {
 
-export interface ObserverSinkEmitter {
+export interface ObserverReportsEmitter {
 	on<K extends keyof SinkEventsMap>(event: K, listener: (reports: SinkEventsMap[K]) => void): this;
@@ -95,3 +95,3 @@ off<K extends keyof SinkEventsMap>(event: K, listener: (reports: SinkEventsMap[K]) => void): this;
 
-export class SinkImpl implements ReportsCollector, ObserverSinkEmitter {
+export class SinkImpl implements ReportsCollector, ObserverReportsEmitter {
 	private _index = 0;
@@ -98,0 +98,0 @@ private _processes = new Map<number, Promise<void>>();

No alert changes

Improved metrics

Total package byte prevSize

966816

increased by0.01%

No dependency changes