SyncTradesImpl. Client

synctradesimpl.kt

class SyncTradesImpl @Inject constructor(@Named("remote") private val remoteRepository: GetTradesRepository,
                                         @Named("local") private val localRepository: GetTradesRepository)
    : SyncTrades {

    override fun syncTrades(id: Long) {
        remoteRepository.getTrades(id).trades
                .map { TradeDb(it.trade_id, it.rate, it.amount, it.trade_date, it.trade_type) }
                .map { localRepository.save(it) }
    }
}