Laimiux

package com.laimiux.dayahead.ui.util;

import android.content.Context;
import android.os.Bundle;
import android.os.Parcelable;
import android.support.v4.view.PagerAdapter;
import android.util.Log;
import android.util.SparseArray;
import android.view.LayoutInflater;
import android.view.View;

Laimiux

public void onAttach(View view) {
  view.showLoading(true)
  repository.getData().subscribe({ data ->
    view.showLoading(false)
    view.showData(data)
  }, { error ->
    view.showLoading(false)
    // should we have a retry action?
    view.showError("boo!")
  })

Laimiux

public void onAttach(View view) {
  repository.getLatestDataStream().subscribe({ data ->
    view.showData(data)
  })
}

Laimiux

// Lce -> Loading / Content / Error
class Lce<T> {
  public static <T> Lce<T> data(T data) {
    // implementation
  }
  public static <T> Lce<T> error(Throwable error) {
    // implementation
  }
  public static <T> Lce<T> loading() {
    // implementation

Laimiux

interface DataRepository {
  Observable<Lce<Data>> getDataEventStream();
}

Laimiux

public void onAttach(View view) {
  // Remember to clean the subscription!
  repository.getDataEventStream().subscribe({ event ->
    if (event.isLoading) {
      view.showLoading(true)
    } else if (event.hasError()) {
      view.showError(event.getError())
    } else {
      view.showData(event.getData())
    } 

Laimiux

Observable<Lce<Data>> getDataEventStream() {
  return api.getData()
    .map(data -> Lce.data(data))
    .startWith(Lce.loading())
    .onErrorReturn(e -> Lce.error(e))
}

Laimiux

final PublishRelay<String> refreshRelay = PublishRelay.create()
  
void refreshData() {
  refreshRelay.call("refresh event")
}

Observable<Lce<Data>> getDataEventStream() {
  return refreshRelay
     .startWith("initial")
     .switchMap { event ->

Laimiux

class UserContent {
 // requires both the user and list of published content
}

Observable<Lce<User>> getUserEventStream(String userId);
Observable<Lce<List<Content>> getContentEventStream(String userId);

Observable<Lce<UserContent>> getProfileEventStream(String id) {
  return Observable.combineLatest(
    getUserEventStream(id),

Laimiux

class UserManager {
  Observable<Lce<User>> getUserEventStream() {
   return updateEventStream().startWith(cachedBundle().map(toLce())) 
  }
}