SyncTrades Server

synctradesimpl.kt

class SyncTradesImpl @Inject constructor(private val localRepository: GetTradesRepository,
                                         private val remoteRepository: GetTradesRepository) : SyncTrades {
    override fun syncTrades(id: Long) {
        remoteRepository.getTrades(id).trades
                .map { TradeStore(it.trade_id, it.rate, it.amount, it.trade_date, it.trade_type) }
                .map { localRepository.save(it) }
    }

}