RxAndroidBle: Setup notification, write on characteristic and wait for notification to proceed
I am using Polidea's RxAndroidBle library to communicate with a Device in my Android application.
I am very new to Reactive Programming so I can't figure out exactly how to do the following:
- Setup Notification in one characteristic (Characteristic A).
- When notification setup is done, write to another characteristic (Characteristic B). This will trigger a Notification coming from Characteristic A.
- When the write operation is done, wait for the arrival of the Notification in Characteristic A.
- Repeat the same steps (1 to 3) many times in different parts of the application.
I have seen this related answer, but it is done using the first version of the library and I can't figure out how to do it using the new version.
Thanks.
android bluetooth-lowenergy rx-java2 rx-android rxandroidble asked Nov 20 '18 at 14:22
dglozanodglozano
931120
add a comment |
I am using Polidea's RxAndroidBle library to communicate with a Device in my Android application.
I am very new to Reactive Programming so I can't figure out exactly how to do the following:
- Setup Notification in one characteristic (Characteristic A).
- When notification setup is done, write to another characteristic (Characteristic B). This will trigger a Notification coming from Characteristic A.
- When the write operation is done, wait for the arrival of the Notification in Characteristic A.
- Repeat the same steps (1 to 3) many times in different parts of the application.
I have seen this related answer, but it is done using the first version of the library and I can't figure out how to do it using the new version.
Thanks.
android bluetooth-lowenergy rx-java2 rx-android rxandroidble asked Nov 20 '18 at 14:22
dglozanodglozano
931120
add a comment |
I am using Polidea's RxAndroidBle library to communicate with a Device in my Android application.
I am very new to Reactive Programming so I can't figure out exactly how to do the following:
- Setup Notification in one characteristic (Characteristic A).
- When notification setup is done, write to another characteristic (Characteristic B). This will trigger a Notification coming from Characteristic A.
- When the write operation is done, wait for the arrival of the Notification in Characteristic A.
- Repeat the same steps (1 to 3) many times in different parts of the application.
I have seen this related answer, but it is done using the first version of the library and I can't figure out how to do it using the new version.
Thanks.
android bluetooth-lowenergy rx-java2 rx-android rxandroidble asked Nov 20 '18 at 14:22
dglozanodglozano
931120
I am using Polidea's RxAndroidBle library to communicate with a Device in my Android application.
I am very new to Reactive Programming so I can't figure out exactly how to do the following:
- Setup Notification in one characteristic (Characteristic A).
- When notification setup is done, write to another characteristic (Characteristic B). This will trigger a Notification coming from Characteristic A.
- When the write operation is done, wait for the arrival of the Notification in Characteristic A.
- Repeat the same steps (1 to 3) many times in different parts of the application.
I have seen this related answer, but it is done using the first version of the library and I can't figure out how to do it using the new version.
Thanks.
android bluetooth-lowenergy rx-java2 rx-android rxandroidble android bluetooth-lowenergy rx-java2 rx-android rxandroidble asked Nov 20 '18 at 14:22
dglozanodglozano
931120
asked Nov 20 '18 at 14:22
dglozanodglozano
931120
edited Dec 2 '18 at 13:32
dglozano
asked Nov 20 '18 at 14:22
dglozanodglozano
931120
asked Nov 20 '18 at 14:22
dglozanodglozano
931120
asked Nov 20 '18 at 14:22
dglozanodglozano
931120
931120
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
I ended figuring it out by myself. Here is a method that setup the indication or notification in a characteristic, then writes some bytes to another characteristic and returns an Observable<String> that emits the byte parsed to a hex String that were read on the notification/indication.
Hope it helps someone else looking for this solution in RxJava2.
private Observable<String> writeAndReadOnNotification(UUID writeTo, UUID readOn,
String hexString,
boolean isIndication,
RxBleConnection rxBleConnection) {
Observable<Observable<byte>> notifObservable =
isIndication ?
rxBleConnection.setupIndication(readOn) :
rxBleConnection.setupNotification(readOn);
return notifObservable.flatMap(
(notificationObservable) -> Observable.combineLatest(
rxBleConnection.writeCharacteristic(writeTo, hexToBytes(hexString)).toObservable(),
notificationObservable.take(1),
(writtenBytes, responseBytes) -> bytesToHex(responseBytes)
)
).take(1)
.observeOn(AndroidSchedulers.mainThread())
.doOnError(this::throwException);
}
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
add a comment |
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53395079%2frxandroidble-setup-notification-write-on-characteristic-and-wait-for-notificat%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
I ended figuring it out by myself. Here is a method that setup the indication or notification in a characteristic, then writes some bytes to another characteristic and returns an Observable<String> that emits the byte parsed to a hex String that were read on the notification/indication.
Hope it helps someone else looking for this solution in RxJava2.
private Observable<String> writeAndReadOnNotification(UUID writeTo, UUID readOn,
String hexString,
boolean isIndication,
RxBleConnection rxBleConnection) {
Observable<Observable<byte>> notifObservable =
isIndication ?
rxBleConnection.setupIndication(readOn) :
rxBleConnection.setupNotification(readOn);
return notifObservable.flatMap(
(notificationObservable) -> Observable.combineLatest(
rxBleConnection.writeCharacteristic(writeTo, hexToBytes(hexString)).toObservable(),
notificationObservable.take(1),
(writtenBytes, responseBytes) -> bytesToHex(responseBytes)
)
).take(1)
.observeOn(AndroidSchedulers.mainThread())
.doOnError(this::throwException);
}
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
add a comment |
I ended figuring it out by myself. Here is a method that setup the indication or notification in a characteristic, then writes some bytes to another characteristic and returns an Observable<String> that emits the byte parsed to a hex String that were read on the notification/indication.
Hope it helps someone else looking for this solution in RxJava2.
private Observable<String> writeAndReadOnNotification(UUID writeTo, UUID readOn,
String hexString,
boolean isIndication,
RxBleConnection rxBleConnection) {
Observable<Observable<byte>> notifObservable =
isIndication ?
rxBleConnection.setupIndication(readOn) :
rxBleConnection.setupNotification(readOn);
return notifObservable.flatMap(
(notificationObservable) -> Observable.combineLatest(
rxBleConnection.writeCharacteristic(writeTo, hexToBytes(hexString)).toObservable(),
notificationObservable.take(1),
(writtenBytes, responseBytes) -> bytesToHex(responseBytes)
)
).take(1)
.observeOn(AndroidSchedulers.mainThread())
.doOnError(this::throwException);
}
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
add a comment |
I ended figuring it out by myself. Here is a method that setup the indication or notification in a characteristic, then writes some bytes to another characteristic and returns an Observable<String> that emits the byte parsed to a hex String that were read on the notification/indication.
Hope it helps someone else looking for this solution in RxJava2.
private Observable<String> writeAndReadOnNotification(UUID writeTo, UUID readOn,
String hexString,
boolean isIndication,
RxBleConnection rxBleConnection) {
Observable<Observable<byte>> notifObservable =
isIndication ?
rxBleConnection.setupIndication(readOn) :
rxBleConnection.setupNotification(readOn);
return notifObservable.flatMap(
(notificationObservable) -> Observable.combineLatest(
rxBleConnection.writeCharacteristic(writeTo, hexToBytes(hexString)).toObservable(),
notificationObservable.take(1),
(writtenBytes, responseBytes) -> bytesToHex(responseBytes)
)
).take(1)
.observeOn(AndroidSchedulers.mainThread())
.doOnError(this::throwException);
}
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
I ended figuring it out by myself. Here is a method that setup the indication or notification in a characteristic, then writes some bytes to another characteristic and returns an Observable<String> that emits the byte parsed to a hex String that were read on the notification/indication.
Hope it helps someone else looking for this solution in RxJava2.
private Observable<String> writeAndReadOnNotification(UUID writeTo, UUID readOn,
String hexString,
boolean isIndication,
RxBleConnection rxBleConnection) {
Observable<Observable<byte>> notifObservable =
isIndication ?
rxBleConnection.setupIndication(readOn) :
rxBleConnection.setupNotification(readOn);
return notifObservable.flatMap(
(notificationObservable) -> Observable.combineLatest(
rxBleConnection.writeCharacteristic(writeTo, hexToBytes(hexString)).toObservable(),
notificationObservable.take(1),
(writtenBytes, responseBytes) -> bytesToHex(responseBytes)
)
).take(1)
.observeOn(AndroidSchedulers.mainThread())
.doOnError(this::throwException);
}
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
answered Nov 24 '18 at 0:27
dglozanodglozano
931120
931120
add a comment |
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53395079%2frxandroidble-setup-notification-write-on-characteristic-and-wait-for-notificat%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
