Fix icc connections not reopened on resolve (#2868)

client/src/app/gateways/base-icc-gateway.service.ts

@@ -33,6 +33,10 @@ export abstract class BaseICCGatewayService<ICCResponseType> {
 
     private connectionClosingFn: (() => void) | undefined;
 
+    private get iccEndpointName(): string {
+        return ICC_ENDPOINT + `_` + this.serviceDescription;
+    }
+
     /**
      * Constructor to create the Service.
      * Subclasses can call {@link setupConnections} after the super call to initialize automatic meeting-based connection handling.
@@ -73,9 +77,9 @@ export abstract class BaseICCGatewayService<ICCResponseType> {
         this.disconnect();
 
         const iccMeeting = `${ICC_PATH}${this.receivePath}?meeting_id=${meetingId}`;
-        this.httpEndpointService.registerEndpoint(ICC_ENDPOINT, iccMeeting, this.healthPath, HttpMethod.GET);
+        this.httpEndpointService.registerEndpoint(this.iccEndpointName, iccMeeting, this.healthPath, HttpMethod.GET);
         const buildStreamFn = () =>
-            this.httpStreamService.create<ICCResponseType>(ICC_ENDPOINT, {
+            this.httpStreamService.create<ICCResponseType>(this.iccEndpointName, {
                 onMessage: (response: ICCResponseType) => this.onMessage(response),
                 description: this.serviceDescription
             });

client/src/app/gateways/http-stream/http-stream.ts

@@ -1,4 +1,10 @@
-import { HttpDownloadProgressEvent, HttpErrorResponse, HttpEvent, HttpHeaderResponse } from '@angular/common/http';
+import {
+    HttpDownloadProgressEvent,
+    HttpErrorResponse,
+    HttpEvent,
+    HttpEventType,
+    HttpHeaderResponse
+} from '@angular/common/http';
 import * as fzstd from 'fzstd';
 import { firstValueFrom, Observable, Subscription } from 'rxjs';
 
@@ -313,8 +319,11 @@ export class HttpStream<T> {
         if (this.isClosed) {
             console.warn(`Got incoming message from stream ${this.id}, but it is closed.`);
             return;
+        } else if (event.type === HttpEventType.Response) {
+            this.reconnect();
+        } else {
+            this._parser.read(event);
         }
-        this._parser.read(event);
     }
 
     private async handleStreamError(error: unknown): Promise<void> {