Pipeline after elasticsearch client runs on okhttp response thread

[jrask]

The code below will print the okhttp response thread name but we want the to be invoked on a scheduler thread.

observable.
buffer(1000)
.flatMap (
    AWS.elasticsearch.client (
     ...
    )
).doOnNext { Event e ->
   println Thread.currentThread().getName()
}

[jrask]

Skip this for now, document that it is recommended to use observeOn(scheduler) in the pipeline until we figure out the best way.