var handleBlocked = (ev: Event) => {
     this.logEvent('dropDatabase', ev)
     observer.error(`Requested database '${databaseName}' is blocked`)
 }

 .onData((data) => observer$.next({type:'DATA',data}) )

			self.query.on(self.convertToString(eventType), callback, err => {
				subscriber.error(err);
			})

 setInterval(_ => { obs.next(++i); }, 1000);

 setInterval(() => obs.next(++i), 1000);

this.socket.on(eventName, (data) => subscriber.next(data));

 request.onsuccess = (ev:Event) => {
     this.logEvent("insertBatch", ev)
     observer.next(i)
     insertRecord()
 };