|
|
|
@ -5,9 +5,6 @@ import { v4 as uuid } from 'uuid';
|
|
|
|
|
|
|
|
|
|
export class RealTimeAPI {
|
|
|
|
|
constructor(param, onOpenCallback, onCloseCallback, onRetryCallback) {
|
|
|
|
|
this.onOpenCallback = onOpenCallback;
|
|
|
|
|
this.onCloseCallback = onCloseCallback;
|
|
|
|
|
this.onErrorCallback = onRetryCallback;
|
|
|
|
|
this.webSocket = webSocket({
|
|
|
|
|
...param,
|
|
|
|
|
openObserver: {
|
|
|
|
@ -22,6 +19,9 @@ export class RealTimeAPI {
|
|
|
|
|
},
|
|
|
|
|
});
|
|
|
|
|
this.retryCount = 0;
|
|
|
|
|
this.onOpenCallback = onOpenCallback;
|
|
|
|
|
this.onCloseCallback = onCloseCallback;
|
|
|
|
|
this.onErrorCallback = onRetryCallback;
|
|
|
|
|
}
|
|
|
|
|
onOpen() {
|
|
|
|
|
console.log(
|
|
|
|
|