We are leaving subscriptions open in 2 situations:
Handshake: Missing Unsubscribe
When streamWriter hands off a subscription to indexedStreamWriter: The Unsubscribe codepath is only in streamWriter via the Close method
This PR adds the missing Unsubscribe for handshakes, and makes so subscriptions handed of to indexedStreamWriter are closed by streamWriter during its Close call.
We are leaving subscriptions open in 2 situations:
streamWriter
hands off a subscription toindexedStreamWriter
: The Unsubscribe codepath is only instreamWriter
via theClose
methodThis PR adds the missing
Unsubscribe
for handshakes, and makes so subscriptions handed of toindexedStreamWriter
are closed bystreamWriter
during itsClose
call.