I think ```var n: Int = 0 read.subscribeOn(<http:...

# rx

[gabrielfv]

I think

var n: Int = 0
read.subscribeOn(<http://Schedulers.io|Schedulers.io>())
        .take(1)
        .takeWhile {
            n += (it % 0x80.toByte).toInt()
            (it and 0x80.toByte()) == 0.toByte()
        }.take(n)

Isn't ideal