michaelzengke

ADDS (Action Delegate Delegatee viewState) — A Kotlin Coroutines Based Android Architecture Pattern

Author: Michael Zeng

Contents

• Introduction
• Kotlin Coroutines Basics
• View State
• Action Worker

michaelzengke

Observable<MyStuff> myStuffRepository = Observable
   .merge(savedJobPostingRepository.onErrorReturn(error -> null),
                    appliedJobPostingRepository.retry(1))
   .reduce(new MyStuff(), (accumulated, item) -> {
     switch (item.getEntityType()) {
       case SavedJobs:
         accumulated.savedJobPostings = item;
         break;
       case AppliedJobs:
         accumulated.appliedJobPostings = item;

michaelzengke

public interface MyStuffEntity {
 EntityType getEntityType();
}

public class MyStuff {
 MyStuffEntity savedJobPostings;
 MyStuffEntity appliedJobPostings;
}

Observable<MyStuff> myStuffRepository = Observable

michaelzengke

Observable<String> powerfulTextViewChangedTextRepository =
   textViewChangedTextRepository.debounce(200, TimeUnit.MILLISECONDS).distinctUntilChanged();

Observable<List<Location>> powerfulLocationTypeAheadOnChangedTextRepository = powerfulTextViewChangedTextRepository
   .switchMap(s -> Observable.just(s).map(text ->RestClientProvider.newLocationTypeAheadClient(text).query()));

michaelzengke

Observable<List<Location>> locationTypeAheadOnChangedTextRepository = textViewChangedTextRepository
   .flatMap(s -> Observable.just(s).map(text -> RestClientProvider.newLocationTypeAheadClient(text).query()))

locationTypeAheadOnChangedTextRepository.subscribe(suggestions -> render(suggestions));

michaelzengke

textViewChangedTextRepository.observeOn(Schedulers.io()).subscribe(s -> System.out.println(s));

michaelzengke

TextView textView = aTextView;

Observable<String> textViewChangedTextRepository = Observable.fromEmitter(emitter -> {
 textView.addTextChangedListener(new TextWatcher() {
   public void onTextChanged(final CharSequence s, final int start, final int before, final int count) {
     emitter.onNext(s.toString());
   }

   public void beforeTextChanged(final CharSequence s, final int start, final int count, final int after) {
   }

michaelzengke

Observable<JobPosting> jobPostingRepository = Observable.just(jobId).observeOn(Schedulers.io())
   .map(jobId -> RestClientProvider.newJobPostingClient(jobId).fetch());

jobPostingRepository.observeOn(AndroidSchedulers.mainThread())
.subscribe(jobPosting -> render(jobPosting));

michaelzengke

jobPostingRepository.subscribe(jobPosting -> render(jobPosting));

michaelzengke

Observable<JobPosting> jobPostingRepository =
   Observable.just(jobId).map(jobId -> RestClientProvider.newJobPostingClient(jobId).fetch());