[execution] IJPL-181190: Use StateFlow instead of handmade ReactiveProperty

GitOrigin-RevId: 974109e7262ba8ef03cc02f4f7302668f17fc875

Author: Walingar

platform/execution-impl/src/com/intellij/execution/ui/RunContentManagerImpl.kt

@@ -23,6 +23,7 @@ import com.intellij.openapi.Disposable
 import com.intellij.openapi.actionSystem.PlatformCoreDataKeys
 import com.intellij.openapi.application.AppUIExecutor
 import com.intellij.openapi.application.ApplicationManager
+import com.intellij.openapi.application.EDT
 import com.intellij.openapi.components.serviceIfCreated
 import com.intellij.openapi.options.advanced.AdvancedSettings
 import com.intellij.openapi.project.Project
@@ -47,6 +48,9 @@ import com.intellij.util.SmartList
 import com.intellij.util.application
 import com.intellij.util.ui.EmptyIcon
 import com.intellij.util.ui.UIUtil
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
 import org.jetbrains.annotations.ApiStatus
 import java.awt.KeyboardFocusManager
 import java.util.concurrent.ConcurrentLinkedDeque
@@ -274,9 +278,11 @@ class RunContentManagerImpl(private val project: Project) : RunContentManager {
     content.putUserData(EXECUTOR_KEY, executor)
     content.displayName = descriptor.displayName
 
-    descriptor.displayNameProperty.afterChange(descriptor) {
-      application.invokeLater {
-        content.displayName = it
+    descriptor.coroutineScope.launch {
+      descriptor.displayNameProperty.collect {
+        withContext(Dispatchers.EDT) {
+          content.displayName = it
+        }
       }
     }
 
@@ -307,9 +313,12 @@ class RunContentManagerImpl(private val project: Project) : RunContentManager {
               content.description = ExecutionBundle.message("process.id.tooltip", pid)
             }
           }
-          descriptor.iconProperty.afterChange(descriptor) {
-            UIUtil.invokeLaterIfNeeded {
-              content.icon = getLiveIndicator(it)
+
+          descriptor.coroutineScope.launch {
+            descriptor.iconProperty.collect {
+              withContext(Dispatchers.EDT) {
+                content.icon = getLiveIndicator(it)
+              }
             }
           }
         }
@@ -333,9 +342,11 @@ class RunContentManagerImpl(private val project: Project) : RunContentManager {
         Disposer.register(disposer, Disposable { processHandler.removeProcessListener(processAdapter) })
       }
     } else {
-      descriptor.iconProperty.afterChange(descriptor) {
-        application.invokeLater {
-          content.icon = it ?: executor.toolWindowIcon
+      descriptor.coroutineScope.launch {
+        descriptor.iconProperty.collect {
+          withContext(Dispatchers.EDT) {
+            content.icon = it ?: executor.toolWindowIcon
+          }
         }
       }
     }

platform/execution/src/com/intellij/execution/ui/ReactiveProperty.kt

@@ -15,6 +15,9 @@
 import com.intellij.openapi.util.NlsContexts.TabTitle;
 import com.intellij.ui.content.Content;
 import kotlinx.coroutines.CoroutineScope;
+import kotlinx.coroutines.flow.MutableStateFlow;
+import kotlinx.coroutines.flow.StateFlow;
+import kotlinx.coroutines.flow.StateFlowKt;
 import org.jetbrains.annotations.ApiStatus;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -34,8 +37,8 @@ public class RunContentDescriptor implements Disposable {
   private ExecutionConsole myExecutionConsole;
   private ProcessHandler myProcessHandler;
   private JComponent myComponent;
-  private final MutableReactiveProperty<@TabTitle @Nullable String> myDisplayNameView = new MutableReactiveProperty<>(null);
-  private final MutableReactiveProperty<@Nullable Icon> myIconView = new MutableReactiveProperty<>(null);
+  private final MutableStateFlow<@TabTitle @Nullable String> myDisplayNameView = StateFlowKt.MutableStateFlow(null);
+  private final MutableStateFlow<@Nullable Icon> myIconView = StateFlowKt.MutableStateFlow(null);
   private final String myHelpId;
   private RunnerLayoutUi myRunnerLayoutUi = null;
   private RunContentDescriptorReusePolicy myReusePolicy = RunContentDescriptorReusePolicy.DEFAULT;
@@ -169,7 +172,7 @@ public void dispose() {
    * @return the icon property that can be observed for the most recent icon value.
    */
   @ApiStatus.Experimental
-  public ReactiveProperty<Icon> getIconProperty() {
+  public StateFlow<Icon> getIconProperty() {
     return myIconView;
   }
 
@@ -211,7 +214,7 @@ public JComponent getComponent() {
    * @return the title property that can be observed for the most recent title value.
    */
   @ApiStatus.Experimental
-  public ReactiveProperty<@Nullable @BuildEventsNls.Title String> getDisplayNameProperty() {
+  public StateFlow<@Nullable @BuildEventsNls.Title String> getDisplayNameProperty() {
     return myDisplayNameView;
   }