Foo.kt

    private fun updateProbes() {
        temperatureProbeService.listTemperatureProbes()
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .flatMapIterable { probes -> probes }
                .flatMap { probe ->
                    val temperature = temperatureProbeService.lastTemperature(probe.serialNumber)
                            .subscribeOn(Schedulers.newThread())
                            .observeOn(AndroidSchedulers.mainThread())
                    Observable.zip(Observable.just(probe), temperature, {one, two -> Pair(one, two)})
                }.subscribe({ probeTemperature ->
                    println("Found probe ${probeTemperature.first.serialNumber} with last recorded " +
                            "temperature of ${probeTemperature.second.temperature} at " +
                            "${probeTemperature.second.time}") },
                { e ->
                    Snackbar.make(findViewById(android.R.id.content)!!,
                            getString(R.string.error_no_internet), Snackbar.LENGTH_LONG)
                            .show()
                },
                { println("Done refreshing"); swipeRefreshLayout.isRefreshing = false })
    }