/fixes #9052 /claim #9052
Issue is that when we pull from a child, when onDone
is run we store the finalizers in the closeLastSubstream
var. However, if the upstream is interrupted before the next time we pull from the child, we’re not running the finalizers.
This PR fixes it by:
closeLastSubstream
is set to null
only when the effect is runonClose
, we also check if the closeLastSubstream != null
and add those finalizers to the effectKyri Petrou
@kyri-petrou
ZIO
@ZIO