Merge pull request #15 from vibe-d/timestamp_unittest

Add timestamp unittest

Author: s-ludwig

source/observable/observable.d

@@ -137,7 +137,7 @@ static assert(isObservable!(ObservableSource!int));
 
 /** Extracts the event tyoe of an observable.
 */
-alias ObservableType(O) = typeof(O.Event.init.eventValue);
+alias ObservableType(O) = TypeOf!(O.Event.Kind.event);
 
 
 /** The fundamental source for generating observable events.
@@ -725,6 +725,7 @@ private struct ObserverNamedTypes(TYPES...)
 	`MonoTime` timestamp of the original occurrence of each event.
 */
 auto timestamp(O)(ref O source)
+	if (isObservable!O)
 {
 	import core.time : MonoTime;
 	alias T = ObservableType!O;
@@ -738,6 +739,25 @@ struct TimestampedEvent(T)
 	MonoTime timestamp;
 }
 
+unittest {
+	import core.time : MonoTime, seconds;
+	import vibe.core.core : runTask;
+
+	MonoTime now = MonoTime.currTime();
+
+	ObservableSource!int source;
+
+	runTask({
+		source.put(1);
+		source.close();
+	});
+
+	foreach (el; source.timestamp.subscribe) {
+		assert(el.event == 1);
+		assert(el.timestamp >= now && el.timestamp <= now + 1.seconds);
+	}
+}
+
 
 /** Forwards the events emitted by an observable with a fixed delay.
 */