clone/opencode
1
0
Fork 0
mirror of https://github.com/anomalyco/opencode.git synced 2026-04-23 22:34:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(session): tighten processor abort handling

Browse Source
This commit is contained in:
Kit Langton
2026-03-27 23:14:01 -04:00
parent 9b4eba1f98
commit cdfdb91403
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/opencode/src/session/processor.ts
View File

@@ -421,6 +421,9 @@ export namespace SessionProcessor {
yield* Stream.fromAsyncIterable(stream.fullStream, (e) => e).pipe(
Stream.runForEachWhile((event) =>
Effect.gen(function* () {
// TODO: Revisit this once more of handleEvent is Effect-native.
// As local synchronous mutation shrinks, this guard and eventually the
// raw AbortSignal plumbing should be removable.
input.abort.throwIfAborted()
yield* handleEvent(event)
return !ctx.needsCompaction
@@ -440,7 +443,7 @@ export namespace SessionProcessor {
)
if (ctx.needsCompaction) return "compact"
if (ctx.blocked || ctx.assistantMessage.error) return "stop"
if (ctx.blocked || ctx.assistantMessage.error || input.abort.aborted) return "stop"
return "continue"
})