🏃Reactive Fitness API Library for Android and RxJava
Alternatives To Rxfit
Project NameStarsDownloadsRepos Using ThisPackages Using ThisMost Recent CommitTotal ReleasesLatest ReleaseOpen IssuesLicenseLanguage
Rxjava46,88210,8608374 days ago57February 13, 202120apache-2.0Java
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Rxjava Android Samples7,548
6 months ago10apache-2.0Java
Learning RxJava for Android by example
Storio2,618124 years ago24May 14, 201742apache-2.0Java
Reactive API for SQLiteDatabase and ContentResolver.
Rsocket Java2,24943602 days ago45September 14, 202243apache-2.0Java
Java implementation of RSocket
Intro To Rxjava2,005
3 years ago24Java
An extensive tutorial on RxJava
Rxjava Essentials Cn1,282
6 years agoCSS
RxJava Essentials 中文翻译版 仅供交流学习使用,严禁商业用途
Spring Reactive Sample1,165
a month ago47gpl-3.0Java
Spring 5 Reactive playground
6 years ago19otherJava
[Deprecated] This project aims to work as a demo project and reference using the common frameworks and tools
Reaktive1,031114 days ago4June 13, 20227apache-2.0Kotlin
Kotlin multi-platform implementation of Reactive Extensions
Rxjava3 Operators Magician904
10 months agoapache-2.0Java
你用不惯 RxJava,只因缺了这把钥匙 🔑
Alternatives To Rxfit
Select To Compare

Alternative Project Comparisons

Reactive Fit API Library for Android

Build Status codecov Download Android Arsenal API

This library wraps the Fit API in RxJava 2 Observables and Singles. No more managing GoogleApiClients! Also, the authorization process for using fitness data is handled by the lib.

See the 1.x branch for a RxJava 1 version of this library.


Create an RxFit instance once, preferably in your Application's onCreate() or by using a dependency injection framework. Make sure to include all the APIs and Scopes that you need for your app. The RxFit class is very similar to the Fitness class provided by the Fit API. Instead of Fitness.HistoryApi.readData(apiClient, dataReadRequest) you can use rxFit.history().read(dataReadRequest). Make sure to have the Location and Body Sensors permission from Marshmallow on, if they are needed by your Fit API requests. If the user didnt already authorize your app for using fitness data, the lib handles showing the authorization dialog.


// Create one instance and share it
RxFit rxfit = new RxFit(
        new Api[] { Fitness.HISTORY_API },
        new Scope[] { new Scope(Scopes.FITNESS_ACTIVITY_READ) }

DataReadRequest dataReadRequest = new DataReadRequest.Builder()
	    .bucketBySession(1, TimeUnit.MINUTES)
	    .setTimeRange(startTime, endTime, TimeUnit.MILLISECONDS)

        .flatMapObservable(dataReadResult -> Observable.from(dataReadResult.getBuckets()))
        .subscribe(bucket -> {
        	/* do something */

An RxFitOnExceptionResumeNext Transformer is available in the lib, which resumes with another Single/Observable when an Exception is thrown, except when the exception was a GoogleAPIConnectionException which was caused by an unresolved resolution.

An optional global default timeout for all Fit API requests made through the library can be set via rxFit.setDefaultTimeout(...). In addition, timeouts can be set when creating a new Observable by providing timeout parameters, e.g. rxFit.history().read(dataReadRequest, 15, TimeUnit.SECONDS). These parameters override the default timeout. When a timeout occurs, a StatusException is provided via onError(). The RxJava timeout operators can be used instead, but these do not cancel the Fit API request immediately.

If you don't want the library to automatically handle resolutions (e.g. for usage in a background service), you can disable this behavior when creating an RxFit instance by passing in false to the handleResolutions parameter: new RxFit(ctx, apiArray, scopeArray, false).

You can also obtain a Single<GoogleApiClient>, which connects on subscribe and disconnects on unsubscribe via GoogleAPIClientSingle.create(...).

The following Exceptions are thrown in the lib and provided via onError():

  • StatusException: When the call to the Fit API was not successful or timed out
  • GoogleAPIConnectionException: When connecting to the GoogleAPIClient was not successful and the resolution (if available) was also not successful (e.g. when the user does not authorize your app to use fitness data). Resolutions are not handled when using GoogleAPIClientObservable.
  • GoogleAPIConnectionSuspendedException: When the GoogleApiClient connection was suspended.
  • SecurityException: When you try to call a Fit API without proper permissions.


A basic sample app is available in the sample project. You need to create an OAuth 2.0 Client ID for the sample app, see the guide in the Fit API docs.


The lib is available on jCenter. Add the following to your build.gradle:

dependencies {
    compile 'com.patloew.rxfit:rxfit2:2.0.1'


When unit testing your app's classes, RxFit behavior can be mocked easily. See the MainPresenterTest in the sample project for an example test.


The code for managing the GoogleApiClient is taken from the Android-ReactiveLocation library by Micha Charmas, which is licensed under the Apache License, Version 2.0.


Copyright 2016 Patrick Lwenstein

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


Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
See the License for the specific language governing permissions and
limitations under the License.
Popular Rxjava Projects
Popular Reactive Projects
Popular Control Flow Categories
Related Searches

Get A Weekly Email With Trending Projects For These Categories
No Spam. Unsubscribe easily at any time.