@@ -0,0 +1,516 @@
+package pl.mbaleczny.instalike.util;%0A%0Aimport io.reactivex.functions.Consumer;%0Aimport io.reactivex.subjects.BehaviorSubject;%0Aimport io.reactivex.subjects.Subject;%0A%0Apublic class Bus%3CT%3E %7B%0A%0A    private Subject%3CT%3E subject = BehaviorSubject.create();%0A%0A    public void post(T item) %7B%0A        subject.onNext(item);%0A    %7D%0A%0A    public void subscribe(Consumer%3CT%3E consumer) %7B%0A        subject.subscribe(consumer);%0A    %7D%0A%0A    public void clear() %7B%0A        subject.onComplete();%0A        subject = BehaviorSubject.create();%0A    %7D%0A%7D%0A

Add Bus util class