RxJavaの非同期処理と新機能ParallelFlowable

この連載はRxJava 2.xを使って、リアクティブプログラミングにおけるポイントやRxJavaが持つ機能について学んでいくことを目的としています。前回まではFlowable／Observableの生成を行うオペレータからそれらのデータを操作するさまざまなオペレータなど、代表的なものについて見てきました。今回はそれらの処理をどのように非同期で実行することができるのかについて見ていきます。加えて、今回はバージョン2.0.5より追加されたParallelFlowableについて簡単に解説します（今回はRxJava 2.1.2で検証しています）。 今回もサンプルはFlowableを使って実装していますが、Observableの場合もバックプレッシャーを扱わない限り、基本的にはほぼ同じ使い方になります。また、データを受け取るSubscriberとして、特別なことをしない限り、第5回で作成したDeb