several more fixes

Author: Aliaksandr.Shpak

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

@@ -134,7 +134,7 @@ class SearchedTextDataPane(val layoutData: String,
     displayText <<< text
 
     private val seachItems: Observable[Seq[SearchElement]] = text.map(s =>
-        s.toCharArray
+        s.toCharArray.filterNot(p => p == '\r')
                 .foldRight(List[List[Char]]())((el, acc) =>
                     acc.headOption.map(head => el :: head).getOrElse(List(el)) :: acc)
                 .zipWithIndex)
@@ -213,6 +213,7 @@ class TableOutputDataPane[T](val layoutData: String,
 
     private val fieldToCols = fields.map(field => FieldToColumn(title = field._1, data = field._2, onSort = if (sorting.isDefinedAt(field._1)) Some(publishSubject()) else None))
     for (f2c <- fieldToCols; onSort <- f2c.onSort; asc <- onSort) sortRecords(f2c.title, asc = asc)
+    for (x <- onLoadNewData; y <- x) println("Read done ")
 
     override def content(): UiWidget = UiPanel(layoutData, Grid("margin 2"), items = Seq(
         new SearchElementsPane[T]("growx", cachedRecordsSubj, searchSelection, compare, searchText),
@@ -223,7 +224,7 @@ class TableOutputDataPane[T](val layoutData: String,
                         selection = selectedRecords,
                         columns = fieldToCols.map(f2c => UiColumn[T](title = f2c.title, value = f2c.data, onSort = (asc: Boolean) => f2c.onSort.get << asc))
                     ),
-                    onLoadNewData.map(_ => UiLink("growx", text = "Click to read next portion of data", onAction = onLoadNewData)))
+                    onLoadNewData.map(action => UiLink("growx", text = "Click to read next portion of data", onAction = action)))
                         .filter(_.isDefined).map(_.get)),
                 UiTabPanel("grow", tabs = behaviorSubject(Seq(
                     UiTab(label = "Raw Output", content = new SearchedTextDataPane("grow", text = selectedRecordValue, defaultSearch = searchText)),

src/main/scala/devtools/lib/rxui/FxRender.scala

@@ -164,7 +164,7 @@ object FxRender {
         override def render(): Button = {
             val c = new Button()
             for (disabled <- link.disabled) c.setDisable(disabled)
-            for (obs <- link.onAction) c.onActionProperty().addListener((_: EventHandler[ActionEvent], _: EventHandler[ActionEvent]) => obs << Unit)
+            c.setOnAction((event: ActionEvent) => link.onAction())
             for (text <- link.text) c.setText(text)
             c
         }

src/main/scala/devtools/lib/rxui/widgets.scala

@@ -55,7 +55,7 @@ case class UiCombo(layoutData: String = "",
 
 case class UiLink(layoutData: String = "",
                   text: Observable[String] = empty(),
-                  onAction: Option[Subject[Unit]] = None,
+                  onAction: () => Unit = () => Unit,
                   disabled: Observable[Boolean] = false) extends UiWidget
 
 case class UiButton(layoutData: String = "",