Me explaining observables to my friends

observable.dart

import 'dart:async';

class Observable {
  Function subscriberFunction;
  Observable(this.subscriberFunction);

  subscribe(observer) {
    this.subscriberFunction(observer);
  }

  pipe(fun) {
    return Observable((observer) {
      return this.subscribe({
        'observe': (v) {
          observer['observe'](fun(v));
        }
      });
    });
  }
}

main() {
  var observable = new Observable((observer) {
    observer['observe']('🐨');
    Timer(Duration(seconds: 10), () {
      observer['observe']('🐈');
    });
  }).pipe((v) => 'i love $v');

  observable.subscribe({
    'observe': (v) {
      print('subscriber #1: $v');
    }
  });

  observable.subscribe({
    'observe': (v) {
      print('subscriber #2: $v');
    }
  });
}