- Fix close of producing tabs

Author: Aliaksandr.Shpak

gradle.properties

@@ -1,3 +1,3 @@
-version = 0.1.3
+version = 0.1.4
 url = https://api.github.com/repos/alshpak/kafka_data_viewer/releases/latest
 update_url = https://github.com/alshpak/kafka_data_viewer/releases

src/main/scala/devtools/kafka_data_viewer/ui/KafkaConnectionsListPane.scala

@@ -47,8 +47,10 @@ class KafkaConnectionsListPane(val layoutData: String = "",
         if (connSeq.size == 1) connMenu(connSeq.head) else Seq()
     )
 
-    private val nameChanges = connections.flatMap(conSeq => from(conSeq.map(_.name)).flatMap(x => x))
-    private val sortedConnections: Observable[Seq[ConnectionDefinition]] = combineLatest(connections, nameChanges).map(_._1).map(connSeq => connSeq.sortBy(_.name.value))
+    private val nameChanges = connections
+            .flatMap(conSeq => from(conSeq.map(_.name))).flatMap(x => x)
+    private val sortedConnections = combineLatest(connections, nameChanges).map(_._1)
+            .map(connSeq => connSeq.sortBy(_.name.value))
 
     override def content(): UiWidget = UiPanel("", Grid(), items = Seq(
         UiPanel("", Grid("margin 5"), items = Seq(UiButton(text = "Add Connection", onAction = onAdd))),

src/main/scala/devtools/kafka_data_viewer/ui/KafkaTopicProducerPanes.scala

@@ -64,7 +64,7 @@ class ProducerPane(val layoutData: String,
     }
     private val producerClosed = publishSubject[ProducerEntry]()
     for (topicData <- $(producerClosed))
-        settings << settings.value.filterNot(topicData ==)
+        settings << settings.value.filterNot(topicData.settings ==)
 
     private val tabsOrdered = publishSubject[Seq[(ProducerEntry, Int)]]()
     for (ordersSeq <- $(tabsOrdered); (entry, order) <- ordersSeq)