ObservableSequence object to store sequence elements; ObservableSequence object to store sequence elements. The default execution is in the current queue.
Ob. ObserveOn method according to parameters of the scheduler whether for SerialDispatchQueueScheduler type, create ObserveOnSerialDispatchQueue object or observeOn object. They inherit from the Producer class and call their respective run methods when they receive a subscription.
Subscribe (sink) from self.source.subscribe(sink) : The sourceObservable, ObservableSequence, iterates over sink’s on (Event) method on its own _scheduler. But will also go to ObserveOnSink or ObserveOnSerialDispatchQueueSink onCore method, And call the schedule in ObserveOnSink or ObserveOnSerialDispatchQueueSink scheduler.
