package io.muun.apollo.domain.action.base;

import rx.Observable;

public abstract class BaseAsyncAction0<R> extends BaseAsyncAction<R> {

    public abstract Observable<R> action();

    public void run() {
        super.run(action());
    }

    public R actionNow() {
        return action().toBlocking().first();
    }
}
