I wondered the same about if subscribe On could spoil things. I'll check.
On 18 May 2014 18:05, "akarnokd" <notifications@github.com> wrote:

> In rxjava-core/src/main/java/rx/operators/OperationToOperator.java:
>
> > +                    public void onError(Throwable e) {
> > +                        sub.onError(e);
> > +                    }
> > +
> > +                    @Override
> > +                    public void onNext(T t) {
> > +                        sub.onNext(t);
> > +                    }
> > +                };
> > +                result.set(Subscribers.from(observer));
> > +                subscriber.add(result.get());
> > +            }
> > +        });
> > +        function.call(observable).unsafeSubscribe(subscriber);
> > +        //because of subscribe command above the result should have been set
> > +        return result.get();
>
> Does this work if function uses subscribeOn and take(1) together? (I can't
> experiment with the code right now).
>
> —
> Reply to this email directly or view it on GitHub<https://github.com/Netflix/RxJava/pull/983/files#r12772625>
> .
>