Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private sendData(data: any, event: SOCKET_EVENTS): Observable<any> {
- if (!this.isConnected) {
- console.error(ERROR_SOCKET_NOT_CONNECTED, event, data);
- const myError: MyError = {
- code: 1,
- message: ERROR_SOCKET_NOT_CONNECTED,
- name: ERROR_SOCKET_NOT_CONNECTED,
- type: MyerrorTypes.NETWORK
- };
- return throwError(myError);
- }
- return new Observable<any>(observer => {
- this.socket
- .emit(event, data, function(responseData: Result<any>) {
- console.log("Data sended", responseData);
- if (responseData.success === true) {
- observer.next(responseData.data);
- observer.complete();
- } else {
- console.error("Data not sended", responseData);
- const myError: MyError = {
- code: responseData.error.code,
- message: responseData.error.text,
- name: ERROR_SOCKET_NOT_CONNECTED,
- type: MyerrorTypes.APPLICATION
- };
- observer.error(myError);
- }
- })
- .once("disconnect", err => {
- console.error("Socket emit disconnect :", err);
- const myError: MyError = {
- code: 1,
- message: ERROR_SOCKET_NOT_CONNECTED,
- name: ERROR_SOCKET_NOT_CONNECTED,
- type: MyerrorTypes.NETWORK
- };
- observer.error(myError);
- });
- }).pipe(takeUntil(this.actions$.pipe(ofType(LOG_OUT))));
- }
Advertisement
Add Comment
Please, Sign In to add comment