fix(stream): Properly release locks

schneiderrequested to merge
schneider/stream-locks into master

Merge request reports