steveorsomethin

function Observable(subscribe) {
  this._subscribe = subscribe;
}

const of = (v) => new Observable(observer => {
  return observer.next(v);
});

Observable.prototype = {
  map(f) {

steveorsomethin

use std::num::{One};

trait Observer<A> {
    fn next(&mut self, val: A);
}

trait Observable<A> {
    fn subscribe<'r, N: Observer<A>>(&mut self, observer: N);

    #[inline]