fix(opencode): untrace streaming event hot paths (#23156)
This commit is contained in:
@@ -213,7 +213,7 @@ export const layer: Layer.Layer<
|
|||||||
return true
|
return true
|
||||||
})
|
})
|
||||||
|
|
||||||
const handleEvent = Effect.fn("SessionProcessor.handleEvent")(function* (value: StreamEvent) {
|
const handleEvent = Effect.fnUntraced(function* (value: StreamEvent) {
|
||||||
switch (value.type) {
|
switch (value.type) {
|
||||||
case "start":
|
case "start":
|
||||||
yield* status.set(ctx.sessionID, { type: "busy" })
|
yield* status.set(ctx.sessionID, { type: "busy" })
|
||||||
|
|||||||
@@ -649,10 +649,10 @@ export const layer: Layer.Layer<Service, never, Bus.Service | Storage.Service> =
|
|||||||
return input.partID
|
return input.partID
|
||||||
})
|
})
|
||||||
|
|
||||||
const updatePartDelta = Effect.fn("Session.updatePartDelta")(function* (input: {
|
const updatePartDelta = Effect.fnUntraced(function* (input: {
|
||||||
sessionID: SessionID
|
sessionID: SessionID
|
||||||
messageID: MessageID
|
messageID: MessageID
|
||||||
partID: PartID
|
partID: PartID
|
||||||
field: string
|
field: string
|
||||||
delta: string
|
delta: string
|
||||||
}) {
|
}) {
|
||||||
|
|||||||
Reference in New Issue
Block a user