Alternative to Observable.fromCallback that does not complete itself