Rust Observables

rust-observable.rs

use Obsevable;
use Observer;

fn main() {
  let observable = new Observable<u8>(|observer: &mut Observer<u8>| {
    observer.next(255);
    observer.complete();
  });
    
  let subscription1 = observable.subscribe({
    next: |value: u8| println("{:?}", value,
    complete: || println("complete"),
    error: |error: Error| println("error: {:?}", error),
  });

  let subscription2 = observable.subscribe(|value: u8| println("{:?}", value);
}