Don't wait till last emission to replace output items

stateful · Dec 4, 2024 · 101dc0a · 101dc0a
1 parent 8a2b96d
commit 101dc0a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/extension/executors/runner/index.ts b/src/extension/executors/runner/index.ts
@@ -15,11 +15,11 @@ import {
   debounceTime,
   map,
   filter,
+  first,
   from,
   scan,
   withLatestFrom,
   Subscription,
-  takeLast,
 } from 'rxjs'
 import { RpcError } from '@protobuf-ts/runtime-rpc'
 
@@ -297,7 +297,7 @@ export const executeRunner: IKernelRunner = async ({
           filter((item) => {
             return isCustomMime(item.mime)
           }),
-          takeLast(1),
+          first(),
         )
         .subscribe({
           next: () => outputs.showOutput(OutputType.outputItems),