Adding in shim support for treating queue-flow as a writable stream. Works in 0.10 but not 0.8 yet