An introduction to Reactive Programming with RxJava – Part #3: Convert a traditional web application to a reactive

In my last two blog entries, I’ve given an introduction to reactive programming and RxJava. In this third and final part I will show how you can convert a traditional web application to a reactive one.

All the code will be available at https://gitlab.com/perlilja/rxAirlineDemo, there will also be the instructions of how to run the application. To get a full insight, I suggest you read the code. The final version is merged to the master branch, and the original version is found on before_rxjava branch.

The application architecture

The application consists of three parts; the third-party API, the backend and the client. The third-party API’s will stay the same, and represent an external API that we don’t have control over. The backend and the client is where we will make the changes to convert a traditional server/client application to a responsive web application. But first, let me explain the traditional web application.

The legacy application architecture

The architecture and the flow of the application is explained in the image below.

It works like this; the client calls the backend, which then makes two calls to each third part API. One call for fetching all possible destinations for an airline for the given source, and thereafter it fetches all flights for each destination. All is done synchronously, which means it will first fetch the data from the EasyJetAPI, and not until it has fetched all the data for that API it will continue to the next one. When fetched all the data from the three different APIs, it will return all the flights in one big JSON response that will be processed and rendered by the client.

Converting to a reactive architecture

To change the web application to a reactive application, we first need to convert the response from the API to an Observable instead. This is easily done by creating an Observable from the response we got from the API, like this:

Observable result = Observable.fromArray(restTemplate.getForObject(encodeURI("http://localhost:10002/easyjet/api/destinations/{from}", from),DestinationDTO[].class));

The next step is to use the new Observable when fetching the data, for example before we did the following:

List possibleEasyJetDestinations = easyJetService.getDestinations(from);

for (DestinationDTO dest : possibleEasyJetDestinations) {
List tmpFlights = easyJetService.getFlights(from, dest.getTo());
tmpFlights.stream().forEach(f -> f.setAirline("EasyJet"));
allFlights.addAll(tmpFlights);
}

Now we can use the power of Observables and first fetch the destinations and then use the flatMap operator to fetch the flights. The subscibeOn method tells the Observable that we want to run this operation in another thread than the main thread. The advantage of doing this, is that each of these services will run in parallel (asynchronously), instead of after each other (synchronously).

easyJetService.getDestinations(from)
.subscribeOn(Schedulers.io())
.flatMap(dest -> easyJetService.getFlights(from, dest.getTo()))
.map(f -> new FlightDTO(f.getFrom(), f.getDestination(), f.getDeparture(), f.getArrival(), f.getPrice(), "EasyJet"))

And now that each service is returning an Observable, we can use merge to join the three Observables that we got from the three different services (one for each external API).

As a last step, we change the FlightsController from returning the response as one big JSON, to instead take the advantage of Server-sent Events (SSE). SSE is a HTML5 standard, where updates or small chunks of data is push to the client. In our case we are sending each FlightDTO as an update to the client. This means that the client doesn’t need to wait for the whole response before it can start rendering the data. Instead it can start render as soon as it receives the first FlightDTO object. The support for SSE is built in Spring Boot, and is supported by most web browsers.

SseEmitter sseEmitter = new SseEmitter();
airlineService.getPossibleDestinations(from).subscribe(a -> {
sseEmitter.send(a);
},sseEmitter::completeWithError,sseEmitter::complete);

return sseEmitter;

I will not explain the client part, but do take a look at the code at Gitlab. The client application is based on Angular 4 and uses RxJS.

Conclusion

So, what are the advantages of using RxJava? The big advantage is that we will get a more reactive application, where the data is displayed to the user in a much faster way. We were also able to divide the execution of the code into different threads, and in that way, make the code less synchronously (and almost three times faster). Of course, we could also have done this with the legacy application, but that wouldn’t be as easy.

And furthermore – even though it’s my very personal opinion – the code becomes much more readable.

Follow up; från produktbolag till konsultbolag – hur gick det?

För nästan ett år sedan tog jag ett stort och svårt beslut. Att efter 14 år på ett och samma företag byta arbetsgivare, och att dessutom gå från produktbolag till konsultbolag, var absolut inget lätt beslut.

Så; hur gick det då?

Sommaren är förhoppningsvis en tid för vila och reflektion för oss alla och för mig var det naturligt att i år reflektera över mina första 6 månader som konsult. Det som jag hela tiden återkommer till när jag ser tillbaka är människor. Det är människorna som gör skillnaden. Jag kom rakt in i ett helt fantastiskt gäng som stöttar och utmanar mig och som jag också har så oerhört kul med. För mig är det ett kvitto på att det som fick mig att välja One, det vill säga värderingarna, inte bara är tryckta på väggen utan i högsta grad efterlevs. Dessutom, och precis lika viktigt, så matchar de mina egna värderingar. Jag har inte bara fått nya kollegor, jag har också fått nya vänner.

En annan sak som lockade med att byta från produktbolag till konsultbolag var möjligheten att få komma ut och hjälpa en mängd olika företag; att hela tiden få chans att utvecklas och lära sig nya saker. Jag är fortfarande ute på mitt första uppdrag så där har jag lite svårt att uttala mig om det lever upp till mina förväntningar, men jag är rätt säker på att jag inte kommer bli besviken. Förhopningen att få komma ut och lära sig nya saker som man inte trodde på förhand kunde inte blir mer rätt. Jag är ute hos en kund som jag aldrig hört talas om innan, i en bransch som jag knappt visste existerade och jag har lärt mig otroligt mycket.

Och de där sakerna som jag oroade mig för, hur är det med dom?

Om vi börjar med att titta på oron över att få ett uppdrag långt bort som gör livspusslet svårare att få ihop så är det klart att den oron kommer när mitt nuvarande uppdrag närmar sig slutet. Skånetrafikens punktlighet de senaste månaderna gör ju inte saken bättre, men precis som min uppfattning var innan så är jag övertygad att vi kan lösa det på bästa sätt för alla inblandade.

Oron över att få ihop en bra teamkänsla när man inte ses varje dag på jobbet är absolut utraderad. Med alla härliga människor, tydliga värderingar och tydlig kommunikation om vad som är viktigt från One Agency’s sida är det absolut inget problem. Förutom att jag gärna hade jobbat ännu tightare med mina fantastiska One-kollegor.

En sak som jag innan inte alls hade reflekterat över innan var hur det här med debitering skulle påverka mig. Det är det enda som jag ibland kan tycka är lite påfrestande – har jag debiterat för många timmar? Har jag debiterat för få timmar? Når jag upp till målet? Jag trodde inte det skulle påverka mig så pass mycket som det faktiskt gör. Här vill jag vara väldigt tydlig med att säga att det inte är någon annan än jag själv som sätter den pressen på mig, och när jag pratar med min chef om det så får jag ett fantastiskt stöd.

Så, om jag skulle fatta beslutet igen att byta från min arbetsgivare till One, skulle jag göra samma val? Absolut!

Courage To Change – and what about the ”magkänsla”?

Vi har alla stått inför val här i livet. Vissa lätta – skinka eller ost på frukostmackan – andra lite svårare – byta jobb, relationer. Vi tar dessa beslut på olika sätt; vi kan basera våra beslut enbart på fakta, göra en lista med för- och nackdelar, be om råd från personer vi litar på eller helt enkelt bara wing it. Och grunden till det sistnämnda är nämligen den berömda magkänslan. Eller möjligtvis den där rösten längst bak i huvudet som många kallar samvete. Den där rösten som rätt snabbt klargör om du är på väg att göra något galet eller om den likt en hejaklacksledare manar dig framåt.

Men kan vi träna upp vår magkänsla? Och isåfall hur? Hur ska vi få den där rösten att guida dig rätt i de beslut som den väljer att göra instick i? Och är det rätt att ta sina beslut helt baserat på just denna? Let’s find out!

Magkänslan är egentligen en blandning av tidigare erfarenheter. Helt omedvetet utvärderar du risk respektive utdelning. Negativa upplevelser, såsom att kastas av en häst, gör att du direkt och omedvetet associerar ridning med hög risk och låg utdelning. Positiva upplevelser, såsom ett lyckat köp av lägenhet, gör att du ser på framtida byten av boende som något med låg risk med hög utdelning. Det är faktiskt så enkelt. Är du glad kommer du att vara mer riskbenägen, medan du i ett ledset eller upprört mode kommer att värdera riskerna högre.

Men det är här det fina kommer in. Debriefing; att utvärdera situationer efter de hänt för att på bästa sätt kunna värdera det som sedan lagras i vår minnesbank. Om vi här kan prata med oss själva kring den där hästen som valde att kasta av oss – varför hände det? Var det något jag gjorde fel eller hade jag bara oturen att välja en bångstyrig ponny? Och glöm för allt i världen inte bort att utvärdera dina positiva upplevelser. Vad gjorde jag som var bra i denna situation och hur kan jag bibehålla denna känsla så länge som möjligt? Således, att faktiskt aktivitet ta beslutet att kunna kontrollera en situation som jag antingen misslyckades i (och lärde mig något av) eller helt enkelt hur jag egentligen lyckades med en uppgift (för att kunna lyckas med den igen eller varför inte göra den ännu bättre).

Så, om vi nu ponerar att vi ska hoppa upp på hästen igen och faktiskt blotta oss för ett nytt eventuellt misslyckande så är det viktigt att man med öppet sinne tagit in information kring sitt misslyckande. Både från sin egna debriefing, men också från omgivningen. Och nu kommer vi till feedback. För vi vet ju alla att feedback är en gåva, eller hur? Den som tar emot den väl kommer att motta den om och om igen. För om jag här i mitt misslyckande ändå har handlingskraften och viljan att vända det hela så behöver jag ju veta hur jag kan göra något bättre. Kan jag göra det bättre? Har jag förutsättningarna för det? Kan jag bli riktigt bra på något?

Vi pratar ofta om handlingskraft och förändringsbenägenhet på One Agency. Mitt egna höstlöfte kommer vara att ta tag i ett 15 år gammalt misslyckande i form av ett uteblivet körkort. Risken är hög och utdelningen känns just nu väldigt låg. Jag står typ längst ner på feedbacktrappan (”det går inte!”) med minnen från en landsvägskörning inkluderande multipla motorstopp påträngande nära. Men, genom att övervinna ovan tankevurpor så tänker jag faktiskt klara detta. Det kommer nog krävas rätt mycket mental träning och därmed känns semestern som en bra start.

Glad, föränderlig och actionfylld sommar!
#CourageToChange #TakeMassiveAction

Digital Animo – Äkta historier om människan bakom tekniken

För några veckor sedan lanserades Digital Animo, en podcast skapad på uppdrag av One Agency. Ordet Animo är latin och betyder mod, passion och hjärta. Podcasten är berättelser om just det; äkta historier om människan bakom Sveriges tech-scen. Cinode bjöd in vår Elise Lilliehöök till en pratstund kring denna; ”Vi på One Agency är övertygade om att det är vi människor som skapar magi och att det kan finnas en idé med att påminna varandra om det ibland. […] Att exempelvis dra på med en påkostad reklamfilm kändes inte särskilt nytänkande eller värdeskapande för oss och någonstans där dök idén upp med en podd istället.”

Skapandet av Digital Animo har gjorts i samarbete med Soundtelling, som drivs bland annat av Martin Johnsson som gör superpodden Spår.

Artikeln på Cinode kan läsas i sin helhet här –> http://bit.ly/2stnIqH.
Podcasten hittar ni på iTunes eller Podbean.