Applies a transformation on the events emitted by an observer.
The return value is an observer that emits the transformed events.
ObservableSource!int source; auto observer = source .map!(i => 2 * i) .subscribe(); source.put(1); source.put(2); source.put(3); assert(observer.consumeOne == 2); assert(observer.consumeOne == 4); assert(observer.consumeOne == 6);
See Implementation
Applies a transformation on the events emitted by an observer.
The return value is an observer that emits the transformed events.