Give streams support for asyncronous processing