Functional Reactive Programming with RxJava • Ben Christensen • GOTO 2013

This presentation was recorded at GOTO Aarhus 2013. #gotocon #gotoaar

Ben Christensen - Software Engineer at Netflix

ABSTRACT
Rxjava is a library for composing asynchronous and event-based programs using observable sequences for the Java VM that supports Java 6+, Clojure, Scala, Groovy, JRuby and Java 8 lambdas.

Come see what functional reactive programming looks like, how it fits into Java, what use cases it addresses and real-world examples of how it can become a tool in your application development.

#FunctionalProgramming #ReactiveProgramming #rxjava #BenChristensen #Netflix

CHANNEL MEMBERSHIP BONUS
Join this channel to get early access to videos & other perks:

Looking for a unique learning experience?

SUBSCRIBE TO OUR CHANNEL - new videos posted almost daily.

[verytiredname]

One of the best presentations on this topic; especially if you are getting started on RxJava

[jondlm]

I've recently been learning RxJs and this presentation was almost entirely applicable to me. I love that these concepts cross language barriers.

[witoldsienski]

One of the best rxjava usage example :)

[tasomaniac]

Great presentation to watch to start my day. :)

[adityadamaraju]

Very helpful presentation, thank you!

[xvitcoder]

Strange, the talk is about rxjava, but the examples are in the unused groovy language. There are 5% of java devs using groovy.

[cccc]

What are vector and scalar response mentioned at @15.000?

[JavierRomero]

Why are all the examples in Groovy vs simply Java? This is RxJava after all but finding actual Java usage is proving to be difficult.

[artyompolyakoff]

Am I the only one who's wondering what was that 'bracket bird' question about?

[marcziel]

compose functions in a reactive manner - you can take a flow of data, transform it as they asynchronously flow through the system and more interestingly combine them together
functional - lambdas, closures, mostly pure, composable (similar to IO monad in haskell)
reactive - asynchronous, values, events, push
rxJava - a library for composing asynchronous and event-based programs using observable sequences
Netflix reached the limit of RESTful API (generic, optimized for nobody)
one network request instead of many to minimize network latency, client logic pushed to the server
nested logic on the server needs to be done concurrently to be performant enough
allow anybody to create endpoints
owner of the API should retain control of concurrency behavior
rx enhancement to observer pattern (from imperative synchronous to declarative asynchronous)
observable allows to achieve higher order functions for transformation and composition on both vectors and scalars
implementation details are abstracted away from how data is consumed (client treats all operations as async but implementation can decide whether it is blocking or what resources it uses)
marble diagrams - a visual representation how data is flowing
reactive programming can be thought as pipes of data flowing together with HOF as connectors