Extend methods such as `client.query(...)` to return an extended Source.
This source now allows it to be awaited directly, and for a subscribe via
a Observable interface to be used.