Handle stream.destroy() called before stream end

Handle stream.destroy() called before stream end #408