Use RxJava Flowable -如何根据事件类型拆分排放

Flowable<String> flowable = Flowable.just("event1", "event2", "event3", "event4");

Flowable<String> event1Flowable = flowable.filter(event -> event.equals("event1"));
Flowable<String> event2Flowable = flowable.filter(event -> event.equals("event2"));
Flowable<String> event3Flowable = flowable.filter(event -> event.equals("event3"));
Flowable<String> event4Flowable = flowable.filter(event -> event.equals("event4"));

event1Flowable.subscribe(event -> System.out.println("Event 1: " + event));
event2Flowable.subscribe(event -> System.out.println("Event 2: " + event));
event3Flowable.subscribe(event -> System.out.println("Event 3: " + event));
event4Flowable.subscribe(event -> System.out.println("Event 4: " + event));