Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import { Injectable } from '@angular/core';
- import { Socket } from 'ngx-socket-io'
- import { Observable } from 'rxjs';
- @Injectable({
- providedIn: 'root'
- })
- export class SocketService {
- constructor(private _socket: Socket) { }
- emit(event: string, args: any) {
- this._socket.emit(event, args)
- }
- awaitResponse() {
- return Observable.create((observer) => {
- this._socket.on('client checked', (data) => {
- observer.next(data)
- })
- })
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement