RxJava example of how to "fix" Observable events going to the main thread

Example.java

public class ShareConnect implements Single.OnSubscribe<Bundle> {

    private final GoogleApiClient client;
    private final Scheduler.Worker worker;
    private final ShareConnectException error;

    public ShareConnect(final Share share) {
        this.client = share.getClient();
        this.worker = Schedulers.io().createWorker();
        this.error = new ShareConnectException("No se ha podido establecer conexión con Google Drive");
    }

    @Override
    public void call(SingleSubscriber<? super Bundle> subscriber) {
        if (client.isConnected() || client.isConnecting()) {
            log("Error: is connected");
            subscriber.onError(error);
        }

        final OnConnectionFailedListener connectionFailedListener = result -> worker.schedule(() -> {
            log("Error: is failed");
            subscriber.onError(error);
        });
        final ConnectionCallbacks connectionListener = new ConnectionCallbacks() {
            @Override
            public void onConnected(@Nullable Bundle bundle) {
                worker.schedule(() -> {
                    log("Connected");
                    subscriber.onSuccess(bundle);
                });
            }

            @Override
            public void onConnectionSuspended(int i) {
                worker.schedule(() -> {
                    log("Error: is suspended");
                    subscriber.onError(error);
                });
            }
        };

        subscriber.add(worker);
        subscriber.add(Subscriptions.create(() -> {
            log("Disconnecting");
            client.unregisterConnectionCallbacks(connectionListener);
            client.unregisterConnectionFailedListener(connectionFailedListener);
            client.disconnect();
        }));

        log("Connecting");
        client.registerConnectionFailedListener(connectionFailedListener);
        client.registerConnectionCallbacks(connectionListener);
        client.connect();
    }
}