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 build

License

Copyright [2016] [Jacek Marchwicki <jacek.marchwicki@gmail.com>]

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.