Implement solution check forwarding

2019-09-06 15:36:40 +02:00
parent 43e43b061d
commit 57db977873
11 changed files with 59 additions and 14 deletions
@@ -28,10 +28,15 @@ export class WebSocketService {
    }
  }

-  public observeKey<T extends WebSocketMessage>(key: string): Observable<T> {
+  public observeControl<T extends WebSocketMessage>(key: string): Observable<T> {
+    return this.observeAll<T>(key).pipe(
+      filter(message => message.intent !== Intent.EVENT)
+    );
+  }
+
+  public observeAll<T extends WebSocketMessage>(key: string): Observable<T> {
    return this.ws.pipe(
      filter(message => message.key.startsWith(key)),
-      filter(message => message.intent !== Intent.EVENT),
      map(message => <T> message)
    );
  }