Added RxJava + Scala Adaptor 0.19.2.
Added a blocking queue with rx.Observable support (onComplete called
when another thread call stop on the queue).