class MyClass {

private final BehaviorSubject<MyEvent> subject;

public MyClass(){
   this.subject = BehaviorSubject.create();
}

@Subscribe //Subscribe to EventBus
void onDataChange(MyEvent event){
   subject.onNext(event);
}

void doWork(){
   myOtherClassInstance.execute(subject, otherParam);
}


}