perf(service): remove onAny function

Author: HyperLife1119

README.md

@@ -136,7 +136,6 @@ export class YourModule { }
 |                | .disconnect()                      | [https://socket.io/docs/v4/client-api/#socketdisconnect](https://socket.io/docs/v4/client-api/#socketdisconnect) |
 |                | .send([...args][, ack])            | [https://socket.io/docs/v4/client-api/#socketsendargs](https://socket.io/docs/v4/client-api/#socketsendargs) |
 |                | .emit(eventName[, ...args][, ack]) | [https://socket.io/docs/v4/client-api/#socketemiteventname-args](https://socket.io/docs/v4/client-api/#socketemiteventname-args) |
-|                | .on()                              | [https://socket.io/docs/v4/client-api/#socketonanycallback](https://socket.io/docs/v4/client-api/#socketonanycallback) |
 |                | .on(eventName)                     | [https://socket.io/docs/v4/client-api/#socketoneventname-callback](https://socket.io/docs/v4/client-api/#socketoneventname-callback) |
 |                | .once(eventName)                   | Similar to `.on(eventName)`, but only responds once. |
 |                | .compress(compress)                | [https://socket.io/docs/v4/client-api/#socketcompressvalue](https://socket.io/docs/v4/client-api/#socketcompressvalue) |

projects/ngx-socketio2/src/lib/socketio.service.ts

@@ -1,13 +1,13 @@
 import { Inject, Injectable, OnDestroy } from '@angular/core';
-import { Observable, Subject } from 'rxjs';
-import { filter, map, take } from 'rxjs/operators';
+import { fromEvent, Observable } from 'rxjs';
+import { FromEventTarget } from 'rxjs/internal/observable/fromEvent';
+import { take } from 'rxjs/operators';
 import { io, Manager, Socket } from 'socket.io-client';
 import { SocketioConfig } from './socketio.interface';
 import { SOCKETIO_CONFIG } from './socketio.token';
 
 @Injectable()
 export class Socketio implements OnDestroy {
-  private subject: Subject<{ eventName: string, args: any[] }> = new Subject();
   private socket: Socket;
 
   /**
@@ -40,14 +40,10 @@ export class Socketio implements OnDestroy {
     @Inject(SOCKETIO_CONFIG) { url, options }: SocketioConfig
   ) {
     this.socket = io(url, options);
-    this.socket.onAny((eventName: string, ...args: any[]) => {
-      this.subject.next({ eventName, args });
-    });
   }
 
   ngOnDestroy(): void {
     this.socket.offAny();
-    this.subject.complete();
   }
 
   /**
@@ -82,30 +78,11 @@ export class Socketio implements OnDestroy {
     return this;
   }
 
-  /**
-   * @see {@link Socket.onAny}
-   */
-  on<T>(): Observable<{ eventName: string, args: T }>
   /**
    * @see {@link Socket.on}
    */
-  on<T>(eventName?: string): Observable<T>
-  on<T extends any>(eventName?: string): Observable<T> | Observable<{ eventName: string, args: T }> {
-    const observable = this.subject.asObservable();
-
-    if (!eventName) {
-      return observable.pipe(
-        map(({ eventName, args }) => ({
-          eventName,
-          args: (args.length === 1 ? args[0] : args) as T
-        }))
-      );
-    }
-
-    return observable.pipe(
-      filter(o => o.eventName === eventName),
-      map(({ args }) => (args.length === 1 ? args[0] : args) as T)
-    );
+  on<T>(eventName: string): Observable<T> {
+    return fromEvent<T>(this.socket as FromEventTarget<T>, eventName);
   }
 
   /**