Emanuele Ianni invasionofsmallcubes

Keybase proof

I hereby claim:

I am invasionofsmallcubes on github.
I am eianni (https://keybase.io/eianni) on keybase.
I have a public key ASAh5nf99-7D7ks37JuV2kKkc_czLn77ISecmqEze2SW6wo

To claim this, I am signing this object:

Here's what's in my head: having everything reactive is actually an utopia.

Everyone of us need to talk to external providers (or just suppose we don't have a reactive driver for mysql/mongodb whatevah).

So I said: I want to achieve the minimum goal which is having the same number of request per second. I tried with just CompletableFuture because I know we have AsyncRestTemplate that we can use with DeferredResult.

Given the same number of threads for:

	// goods/base.go

	package goods

	type base struct {
	name string
	price float64
	exported bool
	}

	{-# LANGUAGE OverloadedStrings #-}

	module Domain ( AreaRole, RoleToAreas, groupByIdentityType ) where

	import Data.Function (on)
	import Data.List (sortBy, groupBy)
	import Data.Ord (comparing)

	data AreaRole = AreaRole {
	role :: String,

	package com.time;

	import org.junit.Test;

	import java.time.Instant;
	import java.time.LocalDateTime;
	import java.time.ZoneId;
	import java.time.ZonedDateTime;
	import java.time.format.DateTimeFormatter;
	import java.util.TimeZone;

	import com.google.common.truth.Truth.assertThat
	import org.junit.Test
	import java.lang.Integer.MAX_VALUE
	import java.lang.Integer.MIN_VALUE
	import java.util.*
	import kotlin.system.measureTimeMillis

	class MinMaxTest {

	fun classicMinMax(elements: IntArray): Pair<Int, Int> {

	// Question is totally stupid but...

	// Example on the book:
	Observable<Observable<String>> delay = just(
	alice.map(w -> "MOO Alice: " + w),
	paolo.map(w -> "MOO Paolo: " + w),
	carmelo.map(w -> "MOO Carmelo: " + w)
	)
	.flatMap(Observable::just)
	.delay(random.nextInt(5), SECONDS);

	Gioco COOP BGG Link Voto BGG Dipendente dalla lingua Gameplay Link Prezzo Parere

	Mysterium https://boardgamegeek.com/boardgame/181304/mysterium 7.4 No https://www.youtube.com/watch?v=vxh4oB0ATrI 41.40 Amazon, 36.00 Philibert Gioco molto carino di deduzione logica. Il contesto da seduta spiritica è molto leggero, anche perché devi passare il gioco a capire gli indizi quindi non ci fai molto caso. La cosa carina è che il fantasma non può parlare, può solo comunicare attraverso i "sogni". Potrebbe ricordare i concetti di Dixit in alcuni punti.
	Legends of Andor https://boardgamegeek.com/boardgame/127398/legends-andor 7.3 Sì https://www.youtube.com/watch?v=xXm2xlsKoSc 35.90 Amazon Gioco con

	static <T> Observable<T> just(T t) {
	return Observable.create(
	s -> {
	s.onNext(t);
	s.onCompleted();
	}
	);
	}

	static <T> Observable<T> never() {

	Hi,
	I watched your presentation about CQRS and Erlang at NDC Oslo.
	Before I ask you something, please now I never used Erlang so it could my
	lack of knowledge on the language that led me to ask you this question.
	I have a question about the demo code:

	`
	attempt_command({withdraw_money, Amount}, State) ->
	NewBalance = State#state.balance - Amount,
	Id = State#state.id,