RxSwift: обеспечение текущего потока при закрытии подписки - PullRequest
1 голос
/ 02 мая 2019

Вопрос очень прост.Гарантируется ли, что без вызова observeOn() - т.е. с использованием CurrentThreadScheduler - закрытие subscribe() будет выполнено в том же потоке (не очереди) вызова?

Впример начальная нить == нить наблюдателя

// <starting thread>
let observable = ... // an observable
observable.subscribe(onNext: { _ in
    // <observer thread>
})

1 Ответ

3 голосов
/ 02 мая 2019

Говорят здесь , что

Когда мы выполняем некоторые операции с Rx, по определению все это делается в одном потоке. Если вы не измените поток вручную, точка входа в цепочку начнется в текущем потоке, а также будет расположена в том же потоке.

Кроме того, планировщиком по умолчанию является CurrentThreadScheduler, который планирует текущий поток

...