Make streams on new async model

[BartolomeyKant]

Streams must own and return reference to StreamWriteAction.
This is nothing more than just object with StateEvent indicating success, failed or stopped events.