move commented-out example from TestScheduler to separate file TestSchedulerExample

Author: samuelgruetter

language-adaptors/rxjava-scala/src/examples/scala/rx/lang/scala/examples/TestSchedulerExample.scala

@@ -0,0 +1,45 @@
+package rx.lang.scala.examples
+
+import org.junit.Test
+import org.scalatest.junit.JUnitSuite
+import scala.concurrent.duration._
+import scala.language.postfixOps
+import rx.lang.scala.{ Observable, Observer }
+import rx.lang.scala.concurrency.TestScheduler
+
+class TestSchedulerExample extends JUnitSuite {
+
+  @Test def testInterval() {
+    import org.mockito.Matchers._
+    import org.mockito.Mockito._
+
+    val scheduler = TestScheduler()
+    // Use a Java Observer for Mockito
+    val observer = mock(classOf[rx.Observer[Long]])
+
+    val o = Observable.interval(1 second, scheduler)
+
+    // Wrap Java Observer in Scala Observer, then subscribe
+    val sub = o.subscribe(Observer(observer))
+
+    verify(observer, never).onNext(0L)
+    verify(observer, never).onCompleted()
+    verify(observer, never).onError(any(classOf[Throwable]))
+
+    scheduler.advanceTimeTo(2 seconds)
+
+    val inOrdr = inOrder(observer);
+    inOrdr.verify(observer, times(1)).onNext(0L)
+    inOrdr.verify(observer, times(1)).onNext(1L)
+    inOrdr.verify(observer, never).onNext(2L)
+    verify(observer, never).onCompleted()
+    verify(observer, never).onError(any(classOf[Throwable]))
+
+    sub.unsubscribe();
+    scheduler.advanceTimeTo(4 seconds)
+    verify(observer, never).onNext(2L)
+    verify(observer, times(1)).onCompleted()
+    verify(observer, never).onError(any(classOf[Throwable]))
+  }
+
+}

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/concurrency/TestScheduler.scala

@@ -2,7 +2,6 @@ package rx.lang.scala.concurrency
 
 import scala.concurrent.duration.Duration
 import rx.lang.scala.Scheduler
-//import org.scalatest.junit.JUnitSuite
 
 /**
  * Scheduler with artificial time, useful for testing.
@@ -66,40 +65,3 @@ object TestScheduler {
   }
 }
 
-//private class UnitTest extends JUnitSuite {
-//  import org.junit.Test
-//  import scala.concurrent.duration._
-//  import scala.language.postfixOps
-//  import rx.lang.scala.{Observable, Observer}
-//
-//  @Test def testInterval() {
-//    import org.mockito.Matchers._
-//    import org.mockito.Mockito._
-//
-//    val scheduler = TestScheduler()
-//    val observer = mock(classOf[rx.Observer[Long]])
-//
-//    val o = Observable.interval(1 second, scheduler)
-//    val sub = o.subscribe(observer)
-//
-//    verify(observer, never).onNext(0L)
-//    verify(observer, never).onCompleted()
-//    verify(observer, never).onError(any(classOf[Throwable]))
-//
-//    scheduler.advanceTimeTo(2 seconds)
-//
-//    val inOrdr = inOrder(observer);
-//    inOrdr.verify(observer, times(1)).onNext(0L)
-//    inOrdr.verify(observer, times(1)).onNext(1L)
-//    inOrdr.verify(observer, never).onNext(2L)
-//    verify(observer, never).onCompleted()
-//    verify(observer, never).onError(any(classOf[Throwable]))
-//
-//    sub.unsubscribe();
-//    scheduler.advanceTimeTo(4 seconds)
-//    verify(observer, never).onNext(2L)
-//    verify(observer, times(1)).onCompleted()
-//    verify(observer, never).onError(any(classOf[Throwable]))
-//  }
-//}
-