Rxjava を使用するプロセスでは、すでに多くの関数コールバックが存在する可能性があります。では、これらの関数コールバックのパラメーターに基づいてデータ ストリームを作成するにはどうすればよいでしょうか?
たとえば、onKeyDown() を変更する必要がある場合、ユーザーが「1、2、3、4」を入力したときの特別な処理など、さまざまなキーストロークに応じてユーザー入力の特定のシーケンスを処理するにはどうすればよいですか。
または、他の関数コールバックがある場合、bufferDebouncezip などの演算子を使用してこれらの関数コールバックからのデータを処理するにはどうすればよいですか?
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
このように書くこともできます
リーリーonKeyDown は、Activity のコールバックです。別のレイヤーでラップするのは不便なので、[いつでもどこでも] データを送信でき、簡単にサブスクライブして送信し、個別に記述することができる Subject を使用します。一般的なコールバックについては、次のように記述できます。Baidu が位置付けているコールバックの雰囲気を説明します。 リーリー
一般的な機能の場合は、次のようにできますリーリー