Change throttle to buffer
Extract interface for Result type.
Allow stream subscription to be asynchronous.
Make the test more asynchronous.