Correctly close netty channels when a stream session ends

Details

Description

Netty channels in stream sessions were not being closed correctly. TL;DR I was using a lambda that was not executing as it is lazily evaluated. This was causing a RejectedExecutionException at the end of some streaming-related dtests