Implemented stream closing, fixed status emitting
Added initial muting api