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

	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 / MyStuffRepository.java

Created October 20, 2016 18:26

	public interface MyStuffEntity {
	EntityType getEntityType();
	}

	public class MyStuff {
	MyStuffEntity savedJobPostings;
	MyStuffEntity appliedJobPostings;
	}

	Observable<MyStuff> myStuffRepository = Observable

michaelzengke / PowerfulLocationTypeAheadRepository.java

Created October 20, 2016 18:25

	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 / LocationTypeAheadRepository.java

Created October 20, 2016 18:24

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

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

michaelzengke / SubscribePrintToUiEventRepository.java

Created October 20, 2016 18:23

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

michaelzengke / UiEventRepository.java

Created October 20, 2016 18:22

	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 / ConcurrencyManagement.java

Created October 20, 2016 18:21

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

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

michaelzengke / SubscribeRenderToJobPostingRepository.java

Created October 20, 2016 18:20

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

michaelzengke / JobPostingRepository.java

Created October 19, 2016 17:50

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

michaelzengke