MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

[rd][debugger] IJPL-177087 Minor improvements in BackendXExecutionStackApi

Browse Source 
GitOrigin-RevId: afb56463d11d204b9168bf3250264a99b0260a18
This commit is contained in:
Alexander Kuznetsov
2025-03-25 02:02:28 +00:00
committed by intellij-monorepo-bot
parent 22f6d6723d
commit d6a649e04b
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/xdebugger-impl/backend/src/com/intellij/platform/debugger/impl/backend/BackendXExecutionStackApi.kt
+7 -6
View File
@@ -34,19 +34,23 @@ internal class BackendXExecutionStackApi : XExecutionStackApi {
override suspend fun computeStackFrames(executionStackId: XExecutionStackId, firstFrameIndex: Int): Flow<XStackFramesEvent> {
val executionStackEntity = debuggerEntity<XExecutionStackEntity>(executionStackId.id) ?: return emptyFlow()
return channelFlow {
val channel = Channel<Deferred<XStackFramesEvent>?>(capacity = Channel.UNLIMITED)
val channel = Channel<Deferred<XStackFramesEvent>>(capacity = Channel.UNLIMITED)
launch {
for (event in channel) {
if (event == null) {
val event = event.await()
this@channelFlow.send(event)
if (event is XStackFramesEvent.ErrorOccurred || event is XStackFramesEvent.XNewStackFrames && event.last) {
channel.close()
this@channelFlow.close()
break
}
this@channelFlow.send(event.await())
}
}
// TODO[IJPL-177087]: executionStackEntity gets removed from DB because new ones come to the flow for some reason,
// so addStackFrames may end abruptly, with not all stack frames shown.
// Investigate whether it's really needed
withEntities(executionStackEntity) {
val executionStack = executionStackEntity.obj
executionStack.computeStackFrames(firstFrameIndex, object : XExecutionStack.XStackFrameContainer {
@@ -69,9 +73,6 @@ internal class BackendXExecutionStackApi : XExecutionStackApi {
XStackFramesEvent.XNewStackFrames(stacks, last)
}
})
if (last) {
channel.trySend(null)
}
}
override fun errorOccurred(errorMessage: @NlsContexts.DialogMessage String) {