Я новичок в мире rxjs и пытаюсь обнять его вокруг. Мое понимание является одной из причин использования rxjs - улучшить производительность с помощью больших наборов данных.rxjs performance array vs stream
Я пытаюсь измерить улучшение скорости, которое вы могли бы получить против нормальных массивов с высокими функциями (карта, уменьшить).
Я создал этот пример здесь https://jsbin.com/bagoli/edit?js,console
Идея заключается в том, чтобы сгенерировать массив и применить некоторые операторы к нему, измеряя время, потраченное.
Я не понимаю, почему расчет потока всегда медленнее. Я что-то упускаю?
Благодарим за помощь.
Я хотел бы упомянуть, что поведение по умолчанию 'Rx.Observable.from' (и я верю' Rx.Observable.fromArray') заключается в использовании текущего планировщика потоков. В случаях, когда вы хотите сделать большую обработку в основном потоке, вы, вероятно, захотите указать другой планировщик ('Rx.Scheduler.default'), чтобы избежать блокировки пользовательского интерфейса. –