RxParse

Usage

find

<T extends ParseObject> Observable<T> ParseObservable.find(ParseQuery<T>);

Before:

ParseUser.getQuery().findInBackground(new FindCallback() {
    @Override
    public done(ParseUser user, ParseException e) {
        if (e == null) System.out.println(user));
    }
});

After:

Observable<ParseUser> users = ParseObservable.find(ParseUser.getQuery());
users.subscribe(user -> System.out.println(user.getObjectId()));

Observable<ParseUser> users = ParseObservable.find(ParseUser.getQuery().setLimit(1000));

count

Before:

ParseUser.getQuery().countInBackground(new CountCallback() {
    @Override
    public done(int count, ParseException e) {
        if (e == null) System.out.println(count));
    }
});

After:

Observable<Integer> count = ParseObservable.from(ParseUser.class).count();
count.subscirbe(c -> System.out.println(c));

loginWithFacebook

Observable<ParseUser> loginUser = ParseObservable.loginWithFacebook(activity);

fetchIfNeeded

Before:

ParseUser.getQuery().fetchIfNeededInBackground(new GetCallback() {
    @Override
    public done(ParseUser user, ParseException e) {
        if (e == null) System.out.println(user));
    }
});

After:

ParseObservable.fetchIfNeeded(user)
    .subscribe(user -> System.out.println(user));

pin

Before:

user.pinInBackground(new SaveCallback() {
    @Override
    public done(ParseException e) {
        // ...
    }
});

After:

ParseObservable.pin(user)
    .subscribe(user -> System.out.println(user));

pin List

Before:

ParseObject.pinAllInBackground(users, new SaveCallback() {
    @Override
    public done(ParseException e) {
        // ...
    }
});

After:

ParseObservable.pin(users)
    .subscribe(user -> System.out.println(user));

save

Before:

user.saveInBackground(new SaveCallback() {
    @Override
    public done(ParseException e) {
        // ...
    }
});

After:

ParseObservable.save(user)
    .subscribe(user -> System.out.println(user));

Instalação

via jcenter

repositories {
    jcenter()
}

dependencies {
    compile 'com.infstory:rxparse:1.0.0'
}

Or via jitpack.io

repositories {
    maven {
        url "https://jitpack.io"
    }
}

dependencies {
    compile 'com.github.yongjhih:rxparse:1.0.0'
}