APISonar


com.badoo.barf.rx.ScheduleOn.io

> com > badoo > barf > rx > ScheduleOn > io
com APIs badoo APIs barf APIs rx APIs ScheduleOn APIs io APIs

Example 1
private void loadConversations(@NonNull Observable<LoadResult<C>> o) {
        mLastLoadResult = null;
        manage(o
            .compose(ScheduleOn.io())
            .subscribe(this::onConversationsLoaded, this::onFatalError));
    }
Example 2
public void onCreateGroupClicked(@NonNull String name) {
        if (TextUtils.isEmpty(name)) {
            mView.showGroupNameEmptyError();
            return;
        }

        final Subscription createGroupSub = mGroupConversation.execute(mUserIds, name)
            .compose(ScheduleOn.io())
            .subscribe(
                mFlowListener::requestOpenChat,
                throwable -> {
                    throw new IllegalStateException("Can't create chat????", throwable);
                });
        manage(createGroupSub);
    }
Example 3
public void onSendMessage(@NonNull M message) {
        manage(mSendMessage.execute(mChatId, message)
            .compose(ScheduleOn.io()).subscribe());
        mView.clearText();
    }