I am new to RxJavaand just trying to implement a few examples to better understand what is happening, so I thought it EditTextwas Observable and emits textChangeEventusing the libraryRxBinding
RxTextView.textChangeEvents(searchbar.getEditText())
.debounce(400, TimeUnit.MILLISECONDS)
.filter(new Func1<TextViewTextChangeEvent, Boolean>() {
@Override
public Boolean call(TextViewTextChangeEvent text) {
return (text.text().length() > 2);
}
})
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(Schedulers.io());
and a Retrofitapi, where is the text to call from Observableabove.
So, I declared a function:
@Override
public Observable<SearchResponse> executeSearch(Observable<RxTextView> queryText) {
return searchService.getSearch(queryText)
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread());
}
And now I need to combine these two, so when the text changes a new call there Retrofit, but I don’t know how I can “pass” the queryTextservice.
I also tried:
Observable<TextViewTextChangeEvent>
searchBarText = RxTextView.textChangeEvents(searchbar.getEditText())
.debounce(400, TimeUnit.MILLISECONDS)
.filter(new Func1<TextViewTextChangeEvent, Boolean>() {
@Override
public Boolean call(TextViewTextChangeEvent text) {
Timber.i("Executes!!! text : %s", text.text().toString());
return (text.text().length() > 2);
}
})
.subscribeOn(AndroidSchedulers.mainThread())
.observeOn(Schedulers.io());
Observable.combineLatest(executeSearchTypeOne(searchBarText), executeSearchTypeTwo(searchBarText),
new Func2<TypeOne, TypeTwo, Object>() {
@Override
public Object call(TypeOne one, TypeTwo two) {
return null;
}
})
.subscribe(new Action1<Object>() {
@Override
public void call(Object o) {
Timber.i("WORKS!!!");
}
});
where I want to start two calls Retrofitat the same time based on the changes EditText, but they do not start at all