RxAndroidBle: Setup notification, write on characteristic and wait for notification to proceed
up vote
0
down vote
favorite
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 at 14:22
dglozano
715120
add a comment |
up vote
0
down vote
favorite
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 at 14:22
dglozano
715120
add a comment |
up vote
0
down vote
favorite
up vote
0
down vote
favorite
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 at 14:22
dglozano
715120
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 at 14:22
dglozano
715120
asked Nov 20 at 14:22
dglozano
715120
edited Dec 2 at 13:32
asked Nov 20 at 14:22
dglozano
715120
asked Nov 20 at 14:22
dglozano
715120
asked Nov 20 at 14:22
dglozano
715120
715120
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
up vote
0
down vote
accepted
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 at 0:27
dglozano
715120
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',
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
up vote
0
down vote
accepted
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 at 0:27
dglozano
715120
add a comment |
up vote
0
down vote
accepted
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 at 0:27
dglozano
715120
add a comment |
up vote
0
down vote
accepted
up vote
0
down vote
accepted
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 at 0:27
dglozano
715120
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 at 0:27
dglozano
715120
answered Nov 24 at 0:27
dglozano
715120
answered Nov 24 at 0:27
dglozano
715120
answered Nov 24 at 0:27
dglozano
715120
715120
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.
Some of your past answers have not been well-received, and you're in danger of being blocked from answering.
Please pay close attention to the following guidance:
- 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
