@@ -0,0 +1,792 @@
+package info.izumin.android.bletia.rx;%0A%0Aimport info.izumin.android.bletia.core.ResolveStrategy;%0Aimport rx.Observable;%0Aimport rx.subjects.PublishSubject;%0A%0A/**%0A * Created by izumin on 11/15/15.%0A */%0Apublic class RxObservableStrategy%3CT, E extends Throwable%3E implements ResolveStrategy%3CT, E, Observable%3CT%3E%3E %7B%0A    public static final String TAG = RxObservableStrategy.class.getSimpleName();%0A%0A    private final PublishSubject%3CT%3E mSubject;%0A%0A    public RxObservableStrategy() %7B%0A        mSubject = PublishSubject.create();%0A    %7D%0A%0A    @Override%0A    public void resolve(T value) %7B%0A        mSubject.onNext(value);%0A    %7D%0A%0A    @Override%0A    public void reject(E throwable) %7B%0A        mSubject.onError(throwable);%0A    %7D%0A%0A    @Override%0A    public Observable%3CT%3E getResolver() %7B%0A        return mSubject;%0A    %7D%0A%7D%0A

Add RxObservableStrategy