neuecc / UniRx

Reactive Extensions for Unity
MIT License
7.01k stars 895 forks source link

fix isRequiredSubscribeOnCurrentThread #448

Open TORISOUP opened 4 years ago

TORISOUP commented 4 years ago

isRequiredSubscribeOnCurrentThread is not working. CurrentThreadScheduler is never used, even if this flag is true.

Observable.Create<int>(o =>
    {
        o.OnNext(1);
        o.OnCompleted();
        return Disposable.Empty;
    }, isRequiredSubscribeOnCurrentThread: true) // not work
    .Repeat()
    .Take(1)
    .Subscribe(x => Debug.Log(x), () => Debug.Log("Stop"))
    .AddTo(this);