feat: handle array events

src/factories/timing-provider-constructor.ts

@@ -274,6 +274,10 @@ export const createTimingProviderConstructor = (
                             ),
                             enforceOrder((event): event is IInitEvent => event.type === 'init'),
                             concatMap((event) => {
+                                if (event.type === 'array') {
+                                    return from(event.events);
+                                }
+
                                 if (event.type === 'init') {
                                     const {
                                         client: { id: clientId },

src/interfaces/array-event.ts

@@ -0,0 +1,8 @@
+import { INoticeEvent } from './notice-event';
+import { IRequestEvent } from './request-event';
+
+export interface IArrayEvent {
+    events: (INoticeEvent | IRequestEvent)[];
+
+    type: 'array';
+}

src/interfaces/index.ts

@@ -1,3 +1,4 @@
+export * from './array-event';
 export * from './candidate-event';
 export * from './check-event';
 export * from './closure-event';

src/types/incoming-signaling-event.ts

@@ -1,4 +1,4 @@
-import { IClosureEvent, IInitEvent, ITerminationEvent } from '../interfaces';
+import { IArrayEvent, IClosureEvent, IInitEvent, ITerminationEvent } from '../interfaces';
 import { TIncomingNegotiationEvent } from './incoming-negotiation-event';
 
-export type TIncomingSignalingEvent = IClosureEvent | TIncomingNegotiationEvent | IInitEvent | ITerminationEvent;
+export type TIncomingSignalingEvent = IArrayEvent | IClosureEvent | TIncomingNegotiationEvent | IInitEvent | ITerminationEvent;