[CASSANDRA-13905] Correctly close netty channels when a stream session ends

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 4.0-alpha1, 4.0
• Component/s: Legacy/Streaming and Messaging
• Severity: Normal
• Assignee: Jason Brown
• Reporter: Jason Brown

Authors

Jason Brown

Reviewers

Ariel Weisberg

• Created: 26/Sep/17 19:31
• Updated: 15/May/20 08:05
• Resolved: 29/Sep/17 16:36

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