Bei der Verwendung von Rxjava gibt es möglicherweise bereits viele Funktionsrückrufe. Wie kann also ein Datenstrom basierend auf den Parametern dieser Funktionsrückrufe erstellt werden?
Wenn ich beispielsweise onKeyDown() ändern muss, wie kann ich eine bestimmte Folge von Benutzereingaben entsprechend den verschiedenen Tastenanschlägen verarbeiten, z. B. eine spezielle Verarbeitung, wenn der Benutzer „1, 2, 3, 4“ eingibt?
Oder wenn es andere Funktionsrückrufe gibt, wie verwendet man Operatoren wie bufferDebouncezip, um Daten aus diesen Funktionsrückrufen zu verarbeiten?
可以这样写
onKeyDown是Activity的回调,不方便再包装一层,因此用了Subject这种可以【随时随地】发射数据、订阅和发射方便分开写的发射器。对于一般的回调可以这样写,给你个百度定位的回调感受一下
对于一般的函数,可以这样