RxAndroidBle is a powerful painkiller for Android's Bluetooth Low Energy headaches. It is backed by RxJava, implementing complicated APIs as handy reactive observables. The library does for you:
- Fancy asynchronous operations support (read, write, notifications)
- Threading management in order to meet Android contracts
- Connection and operation error handling
For support head to StackOverflow #rxandroidble
Read the official announcement at Polidea Blog.
It's your job to maintain single instance of the client. You can use singleton, scoped Dagger component or whatever else you want.
RxBleClient rxBleClient = RxBleClient.create(context);Scanning devices in the area is simple as that:
Subscription scanSubscription = rxBleClient.scanBleDevices()
.subscribe(rxBleScanResult -> {
// Process scan result here.
});
// When done, just unsubscribe.
scanSubscription.unsubscribe();For further BLE interactions the connection is required.
String macAddress = "AA:BB:CC:DD:EE:FF";
RxBleDevice device = rxBleClient.getBleDevice(macAddress);
Subscription subscription = device.establishConnection(context, false) // <-- autoConnect flag
.subscribe(rxBleConnection -> {
// All GATT operations are done through the rxBleConnection.
});
// When done... unsubscribe and forget about connection teardown :)
subscription.unsubscribe();Auto connect concept may be misleading at first glance. Without the autoconnect flag the connection will end up with an error if a BLE device is not advertising when the RxBleDevice#establishConnection method is called. From platform to platform timeout after which the error is emitted differs, but in general it is rather tens of seconds than single seconds.
Setting the auto connect flag allows you to wait until the BLE device becomes discoverable. The RxBleConnection instance won't be emited until the connection is fully set up. It also handles acquiring wakelockes, so it's safe to assume that your Android device will be woken up after the connection has been established.
Be careful not to overuse the autoconnect flag. On the other side it has negative impact on the connection initialization speed. Scanning window and interval is lowered as it is optimized for background use and depending on Bluetooth parameters it may take more time to establish the connection.
device.establishConnection(context, false)
.flatMap(rxBleConnection -> rxBleConnection.readCharacteristic(characteristicUUID))
.subscribe(characteristicValue -> {
// Read characteristic value.
});device.establishConnection(context, false)
.flatMap(rxBleConnection -> rxBleConnection.writeCharacteristic(characteristicUUID, bytesToWrite))
.subscribe(characteristicValue -> {
// Characteristic value confirmed.
}); device.establishConnection(context, false)
.flatMap(rxBleConnection -> Observable.combineLatest(
rxBleConnection.readCharacteristic(firstUUID),
rxBleConnection.readCharacteristic(secondUUID),
YourModelCombiningTwoValues::new
))
.subscribe(model -> {
// Process your model.
}); device.establishConnection(context, false)
.flatMap(rxBleConnection -> rxBleConnection.readCharacteristic(characteristicUuid)
.doOnNext(bytes -> {
// Process read data.
})
.flatMap(bytes -> rxBleConnection.writeCharacteristic(characteristicUuid, bytesToWrite))
.subscribe(writeBytes -> {
// Written data.
}); device.establishConnection(context, false)
.flatMap(rxBleConnection -> rxBleConnection.setupNotification(characteristicUuid))
.doOnNext(notificationObservable -> {
// Notification has been set up
})
.flatMap(notificationObservable -> notificationObservable) // <-- Notification has been set up, now observe value changes.
.subscribe(bytes -> {
// Given characteristic has been changes, here is the value.
});If you want to observe changes in device connection state just subscribe like below. On subscription you will receive the most current state instantly.
device.observeConnectionStateChanges()
.subscribe(connectionState -> {
// Process your way.
});For connection debugging you can use extended logging
RxBleClient.setLogLevel(RxBleLog.DEBUG);Every error you may encounter is provided via onError callback. Each public method has JavaDoc explaining possible errors.
Complete usage examples are located in /sample GitHub repo.
compile "com.polidea.rxandroidble:rxandroidble:1.0.1"<dependency>
<groupId>com.polidea.rxandroidble</groupId>
<artifactId>rxandroidble</artifactId>
<version>1.0.1</version>
<type>aar</type>
</dependency>Using RxAndroidBle enables you to unit test your application easily. For examples how to use mocking head to MockRxAndroidBle.
If you would like to contribute code you can do so through GitHub by forking the repository and sending a pull request.
When submitting code, please make every effort to follow existing conventions and style in order to keep the code as readable as possible. Please also make sure your code compiles by running ./gradlew clean checkstyle test.
- Dariusz Seweryn (dariusz.seweryn@polidea.com)
- Paweł Urban (pawel.urban@polidea.com)
- Michał Zieliński (michal.zielinski@polidea.com)
Copyright 2016 Polidea Sp. z o.o
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.
