yup, that's simpler

src/core/server/http/router/request.ts

@@ -9,7 +9,7 @@
 import { URL } from 'url';
 import uuid from 'uuid';
 import { Request, RouteOptionsApp, RequestApplicationState, RouteOptions } from '@hapi/hapi';
-import { Observable, fromEvent, merge } from 'rxjs';
+import { Observable, fromEvent } from 'rxjs';
 import { shareReplay, first, filter } from 'rxjs/operators';
 import { RecursiveReadonly } from '@kbn/utility-types';
 import { deepFreeze } from '@kbn/std';
@@ -216,14 +216,9 @@ export class KibanaRequest<
   }
 
   private getEvents(request: Request): KibanaRequestEvents {
-    const closed$ = fromEvent<void>(request.raw.res, 'close').pipe(shareReplay(1), first());
-
-    // the response is completed
-    const finished$ = closed$.pipe(filter(() => isCompleted(request)));
+    const completed$ = fromEvent<void>(request.raw.res, 'close').pipe(shareReplay(1), first());
     // the response's underlying connection was terminated prematurely
-    const aborted$ = closed$.pipe(filter(() => !isCompleted(request)));
-    // the response was either finished or aborted
-    const completed$ = merge<void, void>(finished$, aborted$);
+    const aborted$ = completed$.pipe(filter(() => !isCompleted(request)));
 
     return {
       aborted$,