Bridging (subjects, Observable.create)