Nearby handling APIs for Android Apps using RxJava
In your app build.gradle, add
dependencies {
compile 'com.hkurokawa.rxnearby:rxnearby:1.0.0'
}You can watch a sequence of the received messages as an Observable.
RxNearby.subscribe(this, statusResolver)
.subscribe(new Action1<Message>() {
@Override
public void call(Message message) {
// do something
}
});Note you have to provide how to resolve a resolvable status (which means status.hasResolution() returns true) is returned during a sequence of Nearby API calls with the second argument. With this argument, you can specify when the retrial of the subscription should be executed. Internally, it uses Observable.retryWhen() method. See ReactiveX - Retry operator for more information.
final Func1<Status, Observable<Void>> statusResolver = new Func1<Status, Observable<Void>>() {
@Override
public Observable<Void> call(Status status) {
status.startResolutionForResult(MainActivity.this, REQ_RESOLVE_MESSEAGE_API_ERROR);
return retry;
}
};You have to prepare an Observable which emits Message events. Everytime it emits an event, RxNearby Message Publish API is called.
RxNearby.publish(this, sendMessageSubject, statusResolver)
.subscribe(new Action1<PublishResult>() {
@Override
public void call(PublishResult publishResult) {
// do something
}
});T. B. D.
A sample app. to do a simple publish/subject task is under /rxnearby-sample
Copyright (C) 2015 Hiroshi Kurokawa
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.