Upgrade to Pro — share decks privately, control downloads, hide ads and more …

Crack marketing automation with Reactive Streams

Crack marketing automation with Reactive Streams

At HomeAway we strive to automate marketing processes systems using Scala. One of the many challenges we faced concerns the automation of data feeds to our marketing partners, with the purpose of optimizing our dynamic advertising revenue. We’ll take a look at the problems posed by this task, and how Reactive Streams and Akka Streams have played a key role in solving them.

Stefano Bonetti

November 02, 2017
Tweet

More Decks by Stefano Bonetti

Other Decks in Programming

Transcript

  1. package org.reactivestreams; public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {

    } public interface Publisher<T> { public void subscribe(Subscriber<? super T> s); } public interface Subscriber<T> { public void onSubscribe(Subscription s); public void onNext(T t); public void onError(Throwable t); public void onComplete(); } public interface Subscription { public void request(long n); public void cancel(); }