Named Operators

[neuecc]

I'm working in anonymous operator to named operator for performance improvement and readable stacktrace.

for example stack trace of below code are...

Observable.Return(1000)
    .Take(50)
    .Select(x => x)
    .Subscribe(x => Debug.Log(x));

// improvement version

UniRx.SubscribeObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:147)
UniRx.Operators.SelectObserver:OnNext(Int32) (at Assets/UniRx/Scripts/Operators/Select.cs:79)
UniRx.Operators.TakeObserver:OnNext(Int32) (at Assets/UniRx/Scripts/Operators/Take.cs:62)
UniRx.Operators.ReturnObserver:OnNext(Int32) (at Assets/UniRx/Scripts/Operators/Return.cs:48)
UniRx.Operators.Return`1:SubscribeCore(IObserver`1, IDisposable) (at Assets/UniRx/Scripts/Operators/Return.cs:23)
UniRx.Operators.OperatorObservableBase`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Operators/OperatorObservableBase.cs:40)
UniRx.Operators.Take`1:SubscribeCore(IObserver`1, IDisposable) (at Assets/UniRx/Scripts/Operators/Take.cs:38)
UniRx.Operators.OperatorObservableBase`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Operators/OperatorObservableBase.cs:40)
UniRx.Operators.Select`2:SubscribeCore(IObserver`1, IDisposable) (at Assets/UniRx/Scripts/Operators/Select.cs:48)
UniRx.Operators.OperatorObservableBase`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Operators/OperatorObservableBase.cs:40)
UniRx.ObservableExtensions:Subscribe(IObservable`1, Action`1) (at Assets/UniRx/Scripts/Observer.cs:260)
UniRx.ObjectTest.UniRxTestSandbox:OnGUI() (at Assets/ObjectTest/UniRxTestSandbox.cs:354)

// current assetstore version

UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.<Select>c__AnonStoreyDE`2:<>m__1E0(Int32) (at Assets/UniRx/Scripts/Observable.cs:39)
UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.<Take>c__AnonStoreyA0`1:<>m__1A0(Int32) (at Assets/UniRx/Scripts/Observable.Paging.cs:28)
UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.AnonymousObserver`1:OnNext(Int32) (at Assets/UniRx/Scripts/Observer.cs:55)
UniRx.<Return>c__AnonStorey71`1:<>m__183() (at Assets/UniRx/Scripts/Observable.Creation.cs:121)
UniRx.ImmediateScheduler:Schedule(Action) (at Assets/UniRx/Scripts/Schedulers/ImmediateScheduler.cs:26)
UniRx.<Return>c__AnonStorey70`1:<>m__D2(IObserver`1) (at Assets/UniRx/Scripts/Observable.Creation.cs:119)
UniRx.AnonymousObservable`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Observable.Creation.cs:46)
UniRx.ObservableExtensions:Subscribe(IObservable`1, Action`1, Action`1, Action) (at Assets/UniRx/Scripts/Observer.cs:173)
UniRx.<Take>c__AnonStorey9F`1:<>m__EB(IObserver`1) (at Assets/UniRx/Scripts/Observable.Paging.cs:23)
UniRx.AnonymousObservable`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Observable.Creation.cs:46)
UniRx.<Select>c__AnonStoreyDD`2:<>m__10A(IObserver`1) (at Assets/UniRx/Scripts/Observable.cs:27)
UniRx.<Subscribe>c__AnonStorey11F:<>m__210() (at Assets/UniRx/Scripts/Observable.Creation.cs:42)
UniRx.InternalUtil.ScheduledItem:Invoke() (at Assets/UniRx/Scripts/InternalUtil/ScheduledItem.cs:44)
UniRx.Trampoline:Run(SchedulerQueue) (at Assets/UniRx/Scripts/Schedulers/CurrentThreadScheduler.cs:122)
UniRx.CurrentThreadScheduler:Schedule(TimeSpan, Action) (at Assets/UniRx/Scripts/Schedulers/CurrentThreadScheduler.cs:91)
UniRx.CurrentThreadScheduler:Schedule(Action) (at Assets/UniRx/Scripts/Schedulers/CurrentThreadScheduler.cs:69)
UniRx.AnonymousObservable`1:Subscribe(IObserver`1) (at Assets/UniRx/Scripts/Observable.Creation.cs:42)
UniRx.ObservableExtensions:Subscribe(IObservable`1, Action`1) (at Assets/UniRx/Scripts/Observer.cs:158)
UniRx.ObjectTest.UniRxTestSandbox:OnGUI() (at Assets/ObjectTest/UniRxTestSandbox.cs:526)

Please wait a moment for easy to debug!

rest of operators list---

• [x] Scan
• [x] Multicast
• [x] Publish
• [x] PublishLast
• [x] Replay
• [x] RefCount
• [x] Wait
• [x] Concat
• [x] Merge
• [x] Zip
• [x] CombineLatest
• [x] Switch
• [x] WhenAll
• [x] StartWith
• [x] Synchronize
• [x] ObserveOn
• [x] SubscribeOn
• [x] DelaySubscription
• [x] Amb
• [x] AsObservable
• [x] ToObservable
• [x] Cast
• [x] OfType
• [x] AsUnitObservable
• [x] Create
• [x] Empty
• [x] Never
• [x] Return
• [x] Throw
• [x] Range
• [x] Repeat
• [x] RepeatSafe
• [x] Defer
• [x] Start
• [x] ToAsync
• [x] Select
• [x] Where
• [x] SelectMany
• [x] ToArray
• [x] Do
• [x] Materialize
• [x] Dematerialize
• [x] DefaultIfEmpty
• [x] Distinct
• [x] DistinctUntilChanged
• [x] IgnoreElements
• [x] ForEachAsync
• [x] Finally
• [x] Catch
• [x] CatchIgnore
• [x] Retry
• [x] OnErrorRetry
• [x] FromEventPattern
• [x] FromEvent
• [x] FromAsyncPattern
• [x] Take
• [x] TakeWhile
• [x] TakeUntil
• [x] Skip
• [x] SkipWhile
• [x] SkipUntil
• [x] Buffer
• [x] Pairwise
• [x] Last
• [x] LastOrDefault
• [x] First
• [x] FirstOrDefault
• [x] Single
• [x] SingleOrDefault
• [x] Interval
• [x] Timer
• [x] Timestamp
• [x] TimeInterval
• [x] Delay
• [x] Sample
• [x] Throttle
• [x] ThrottleFirst
• [x] Timeout
• [x] FromCoroutine
• [x] SampleFrame
• [x] ThrottleFrame
• [x] ThrottleFirstFrame
• [x] TimeoutFrame
• [x] DelayFrameSubscription
• [x] RepeatUntil***

[neuecc]

More Improvment StackTrace.

This stacktrace indicates Where().Select().Take().Subscribe() Extremely clear and gets more performance!

[neuecc]

I've done all. I'll release next version(5.0) soon.

[neuecc]

New version is very fast.

• Check Subscribe Speed, 10000 subject with the operators .Where(x => x % 2 == 0).Select(x => x * x).Take(10).Subscribe()
• Check OnNext Speed, 10000 ReactiveProperty change the value with the operator .Where(x => x % 2 == 0).Select(x => x * x).Take(10).Subscribe()

Old: Subscribe = 457ms OnNext = 11ms

New: Subscribe = 38ms OnNext = 2.6ms

[neuecc]

Release UniRx 5.0.0.