RxRatpack

RxRatpack.groovy

@Grab("io.ratpack:ratpack-rx:0.9.1")

import ratpack.launch.*
import ratpack.rx.internal.*

def cfg = LaunchConfigBuilder.baseDir(new File("/tmp")).build()
def rx = new DefaultRxBackground(cfg.background)

def list = ['fee', 'fie', 'fo', 'fum']
def str = ""

rx.observeEach { list }
.map { it.toLowerCase() }
.subscribe({
    println "event"
    str += it
}, { Throwable err ->
    throw err
}, {
    println "done :-) $str"
})