Rxjava를 사용하는 과정에서 이미 많은 함수 콜백이 있을 수 있는데, 이러한 함수 콜백의 매개변수를 기반으로 데이터 스트림을 생성하는 방법은 무엇입니까?
예를 들어 onKeyDown()을 수정해야 하는 경우 사용자가 "1, 2, 3, 4"를 입력할 때의 특수 처리와 같이 다양한 키 입력에 따라 특정 사용자 입력 순서를 어떻게 처리할 수 있습니까?

또는 다른 함수 콜백이 있는 경우 bufferDebouncezip과 같은 연산자를 사용하여 이러한 함수 콜백의 데이터를 처리하는 방법은 무엇입니까?