Const RxjsPoweredWritableListMediator
RxjsPoweredWritableListMediator: any = WritableListMediator.extend({Properties: 'globalSubr, emitEventDelay',init: function(settings: IWritableListMediatorCtorOptions) {const self: IRxjsPoweredDirContentMediatorDev = this;self._super(settings);self._globalSubr = null;self._emitEventDelay = 1000;},/*** Starts to listen to the change on the global provider.* It is usually used internally on setting up this mediator.* @param {Object} globalProvider*/startListeningGlobalProvider: function(globalProvider) {const self: IRxjsPoweredDirContentMediatorDev = this;self._globalProvider = globalProvider;const eventObserver = fromEvent(globalProvider, 'update');const ctrlObserver = eventObserver.pipe(debounceTime(self._emitEventDelay));self._globalSubr = eventObserver.pipe(buffer(ctrlObserver),map((col) => {const x = mergeArgs(col);return x;})).subscribe(args => {self.onGlobalProviderUpdate.apply(self, [null, args]);});},/*** Stops listening to the change on the global provider.* It is usally used on the tearing down this mediator.*/stopListeningGlobalProvider: function() {const self: IRxjsPoweredDirContentMediatorDev = this;const globalProvider = self._globalProvider;if (self._globalSubr) {self._globalSubr.unsubscribe();self._globalSubr = null;}}})