public static function fromIterator(\Iterator $iterator, SchedulerInterface $scheduler = null): IteratorObservable
    {
        return new IteratorObservable($iterator, $scheduler ?: Scheduler::getDefault());
    }