Kasper Kondzielski ghostbuster91

## withdraw_service_story_8.scala
def distinctUntilChanged[AA >: A](implicit A: Eq[AA]): Observable[AA]

## withdraw_service_story_7.scala
Observable
  .intervalWithFixedDelay(config.interval)
  .mapEval( _=> repository.findAllWaitingOrderedBySerialIdAsc())
  .flatMap(Observable.fromIterable)
  .bufferTimeAndCounted(config.timeWindow, config.batchSize)

## withdraw_service_story_6.scala
Observable
  .intervalWithFixedDelay(config.interval)
  .mapEval( _=> repository.findAllWaitingOrderedBySerialIdAsc())
  .flatMap(Observable.fromIterable)

## withdraw_service_story_5.scala
Observable
  .intervalWithFixedDelay(config.interval)
  .mapEval( _=> repository.findAllWaitingOrderedBySerialIdAsc())
  .map( list => list.groupBy(_.currency))

## withdraw_service_story_4.scala
def startExecutor =
  Observable
    .intervalWithFixedDelay(config.interval)
    .mapEval(_=> repository.findAllWaitingOrderedBySerialIdAsc())

## withdraw_service_story_3.scala
class WithdrawalBatchingExecutor(repository: WithdrawalRepository,
                                 externalSystem: ExternalWithdrawSystem) {

  def startExecutor = ???
}

## withdraw_service_story_2.scala
trait ExternalWithdrawSystem {
  def executeWithdrawals(List[Withdraw]) : Task[Unit]
}

## withdraw_service_story_1.scala
trait WithdrawalRepository {
  def findAllWaitingOrderedBySerialIdAsc() : Task[List[Withdrawal]]
}

## how_to_run_dockers_ci_4.sh
docker-compose --project-name ${BUILD_ID} down

## how_to_run_dockers_ci_3.sh
docker-compose --project-name ${BUILD_ID} up -d
	Observable
	.intervalWithFixedDelay(config.interval)
	.mapEval( _=> repository.findAllWaitingOrderedBySerialIdAsc())
	.flatMap(Observable.fromIterable)
	.bufferTimeAndCounted(config.timeWindow, config.batchSize)
	def startExecutor =
	Observable
	.intervalWithFixedDelay(config.interval)
	.mapEval(_=> repository.findAllWaitingOrderedBySerialIdAsc())
	class WithdrawalBatchingExecutor(repository: WithdrawalRepository,
	externalSystem: ExternalWithdrawSystem) {

	def startExecutor = ???
	}
	trait ExternalWithdrawSystem {
	def executeWithdrawals(List[Withdraw]) : Task[Unit]
	}
	trait WithdrawalRepository {
	def findAllWaitingOrderedBySerialIdAsc() : Task[List[Withdrawal]]
	}