lce-refreshable-stream.java

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

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