File tree Expand file tree Collapse file tree 3 files changed +5
-4
lines changed
language-adaptors/rxjava-scala/src
examples/scala/rx/lang/scala/examples Expand file tree Collapse file tree 3 files changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ import scala.concurrent.duration._
22
22
import org .junit .{Before , Test , Ignore }
23
23
import org .junit .Assert ._
24
24
import rx .lang .scala .concurrency .NewThreadScheduler
25
- import rx .lang .scala .util .Timestamped
25
+ import rx .lang .scala .util .{ Timestamped , TimestampedObject }
26
26
27
27
@ Ignore // Since this doesn't do automatic testing, don't increase build time unnecessarily
28
28
class RxScalaDemo extends JUnitSuite {
@@ -378,7 +378,7 @@ class RxScalaDemo extends JUnitSuite {
378
378
379
379
@ Test def timestampExample () {
380
380
val timestamped = Observable .interval(100 millis).take(3 ).timestamp.toBlockingObservable
381
- for (Timestamped (millis, value) <- timestamped if value > 0 ) {
381
+ for (TimestampedObject (millis, value) <- timestamped if value > 0 ) {
382
382
println(value + " at t = " + millis)
383
383
}
384
384
}
Original file line number Diff line number Diff line change @@ -199,7 +199,7 @@ class Observable[+T](val asJava: rx.Observable[_ <: T])
199
199
* @return an Observable that emits timestamped items from the source Observable
200
200
*/
201
201
def timestamp : Observable [Timestamped [T ]] = {
202
- Observable [rx.util.Timestamped [_ <: T ]](asJava.timestamp()).map(Timestamped (_))
202
+ Observable [rx.util.Timestamped [_ <: T ]](asJava.timestamp()).map(TimestampedObject (_))
203
203
}
204
204
205
205
/**
Original file line number Diff line number Diff line change @@ -45,7 +45,8 @@ package object util {
45
45
46
46
class Timestamped [+ T ](val asJava : rx.util.Timestamped [_ <: T ]) {}
47
47
48
- object Timestamped {
48
+ // TODO rename this to Timestamped without making scalac crash
49
+ object TimestampedObject {
49
50
def apply [T ](timestampMillis : Long , value : T ): Timestamped [T ] = {
50
51
new Timestamped (new rx.util.Timestamped (timestampMillis, value))
51
52
}
You can’t perform that action at this time.
0 commit comments