class DiskDatumDataStore{

        var remoteData: Observable<Data>? = null

        var localData: Observable<Data>? = null

 override fun sync() {
          //находим свежие remote данные
         remoteDatums = getChangedRemoteData(lastUpdated!!, 1000)!!
          localDatums = remoteDatums!!.map {
               getIdsInDatumsRemote(it)
          }.map {
              it.map {
                  it.toLong()
              }
          }.flatMap {
              getOldLocalData(it)
          }

       //Что -то делаем с localData и remoteData
         identifyDatumsForUpdate(datumsForUpdateLocal, datumsForUpdateRemote)
      }

  override fun getOldLocalData(remoteDatumsIds: List<Long>): Observable<List<DataLayerTypesOfResponsibility>> {
          return Observable.fromCallable { repository.getOldDatum(remoteDatumsIds) }

      }