Какие механизмы используются в RxJava для управления переключением потоков исполнения?