I want to do something like the following: ```read...

# rx

[gabrielfv]

I want to do something like the following:

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

Except that n is a value that I determine based on the bytes I caught through takeWhile. How can I fetch this value before performing the take(n)?