Extensions to RxJava
This library allow simple implementation for some tasks in android
Usage
Add library to project dependencies.
repositories {
maven { url "https://jitpack.io" }
}
dependencies {
// snapshot version
compile 'com.github.jacek-marchwicki.rx-java-extensions:rx-extensions:master-SNAPSHOT'
compile 'com.github.jacek-marchwicki.rx-java-extensions:rx-android-extensions:master-SNAPSHOT'
// or use specific version
compile 'com.github.jacek-marchwicki.rx-java-extensions:rx-extensions:<look-on-release-tab>'
compile 'com.github.jacek-marchwicki.rx-java-extensions:rx-android-extensions:<look-on-release-tab>'
}If you have separate project for java you can use there only rx-extensions, and add
rx-android-extensions to android module.
Examples
In examples we use sample rest guestbok python server
Get retrofit
- Error managment
- Automatically retry when error
- Refresh button
- In memory cache with timeout
Observable<ResponseOrError<Response>> observable = retrofitService.getItem(id)
.compose(ResponseOrError.<Response>toResponseOrErrorObservable())
.compose(MoreOperators.<Response>repeatOnError(networkScheduler))
.compose(MoreOperators.<ResponseOrError<Response>>refresh(refreshSubject))
.compose(MoreOperators.<ResponseOrError<Response>>cacheWithTimeout(networkScheduler));Load more
- Load more
- Manage errors
- Automatically retry when error
- Refresh button
- In memory cache with timeout
final OperatorMergeNextToken<Response, Object> mergeNextToken = OperatorMergeNextToken
.create(new Func1<Response, Observable<Response>>() {
@Override
public Observable<Response> call(@Nullable final Response response) {
if (response == null) {
// Load data
return itemsService.listItems(null)
.subscribeOn(networkScheduler);
} else {
final String nextToken = response.nextToken();
if (nextToken == null) {
// detect when there is no more data
return Observable.never();
}
// return more data
final Observable<Response> apiRequest = itemsService.listItems(nextToken)
.subscribeOn(networkScheduler);
// join with previous response
return Observable.just(response).zipWith(apiRequest, new MergeTwoResponses());
}
}
});
Observable<ResponseOrError<Response>> data = loadMoreSubject
.startWith((Object) null)
.lift(mergeNextToken)
.compose(ResponseOrError.<Response>toResponseOrErrorObservable())
.compose(MoreOperators.<Response>repeatOnError(networkScheduler))
.compose(MoreOperators.<ResponseOrError<Response>>refresh(refreshSubject))
.compose(MoreOperators.<ResponseOrError<Response>>cacheWithTimeout(networkScheduler));Get title from response
- Map error responses
- Concurent subscriptions use same response
Observable<ResponseOrError<String>> titleObservable = itemsDao.dataObservable()
.compose(ResponseOrError.map(new Func1<Response, String>() {
@Override
public String call(Response response) {
return response.title();
}
}))
.subscribeOn(networkScheduler)
.observeOn(uiScheduler)
.compose(ObservableExtensions.<ResponseOrError<String>>behaviorRefCount());Combine errors from multiple observers
Observable<Throwable> errorObservable =
ResponseOrError.combineErrorsObservable(ImmutableList.of(
ResponseOrError.transform(titleObservable),
ResponseOrError.transform(itemsObservable)));Combine progress from multiple observers
Observable<Boolean> progressObservable =
ResponseOrError.combineProgressObservable(ImmutableList.of(
ResponseOrError.transform(titleObservable),
ResponseOrError.transform(itemsObservable)));Bind data to views
presenter.titleObservable()
.compose(lifecycleMainObservable.<String>bindLifecycle())
.subscribe(MoreViewActions.setTitle(toolbar));
presenter.progressObservable()
.compose(lifecycleMainObservable.<Boolean>bindLifecycle())
.subscribe(ViewActions.setVisibility(progress, View.INVISIBLE));
presenter.errorObservable()
.map(ErrorHelper.mapThrowableToStringError())
.compose(lifecycleMainObservable.<String>bindLifecycle())
.subscribe(ViewActions.setText(error));Build instructions
./gradlew buildLicense
Copyright [2016] [Jacek Marchwicki <[email protected]>]
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.