I'm trying to get my head around the `rxpy` library for functional reactive programming (FRP) and I've already hit a roadblock. I'm writing a small program that expects data to be streamed in via standard input (`sys.stdin`).

My question is therefore simple: how can I create an `rx.Observable` instance that will asynchronously read from stdin? Are there built-in mechanisms to create `Observable` instances from streams?