RxJavaSubjectDemo.java

interface SootEvent { }
class SomeSootEvent implements SootEvent { ... }

class Foo {
    PublishSubject<SootEvent> eventSubject = PublishSubject.create();

    void modifyState() {
        // ... modify some state ...
        eventSubject.onNext(new SomeSootEvent(...));
    }
}

class EventHandler {
    void handleEventsOf(PublishSubject<SootEvent> eventSubject) {
        eventSubject.parallel()
                    .runOn(Schedulers.computation())
                    .map(event -> someTransformation(event))
                    .subscribe(transformedEvent -> doSomethingWith(transformedEvent))
    }
}