package com.campudus.scycle

import rxscalajs.subscription.AnonymousSubscription
import rxscalajs.{Observable, Subject}

trait Driver[A] {

  def createSubject(): Subject[A] = {
    org.scalajs.dom.console.log("in Driver.createSubject()")
    val s = Subject.apply[A]()
    org.scalajs.dom.console.log("after Driver.createSubject:Subject.apply()")
    s
  }

  def subscribe(inputs: Observable[A]): AnonymousSubscription = inputs.subscribe(_ => null)

}

package com.campudus.scycle

import rxscalajs.subscription.AnonymousSubscription
import rxscalajs.{Observable, Subject}

trait Driver[A] {

  def createSubject(): Subject[A] = Subject()

  def subscribe(inputs: Observable[A]): AnonymousSubscription = inputs.subscribe(_ => null)

}

--- 
+++ 
@@ -5,7 +5,12 @@
 
 trait Driver[A] {
 
-  def createSubject(): Subject[A] = Subject()
+  def createSubject(): Subject[A] = {
+    org.scalajs.dom.console.log("in Driver.createSubject()")
+    val s = Subject.apply[A]()
+    org.scalajs.dom.console.log("after Driver.createSubject:Subject.apply()")
+    s
+  }
 
   def subscribe(inputs: Observable[A]): AnonymousSubscription = inputs.subscribe(_ => null)
 
Add debug to driver - cannot see any further

Signed-off-by: Joern Bernhardt <7b85a41a628204b76aba4326273a3ccc74bd009a@campudus.com>
