Simples asynchronous RxScala example

rxScala.scala

Observable(
  subscriber => {
    new Thread(new Runnable() {
      def run() {
          val i = 0  // do real shit here instead
          subscriber.onNext(i)
        }
        if (!subscriber.isUnsubscribed) {
          subscriber.onCompleted()
        }
      }
    }).start()
  }
)