Fixed closing order of bounded queue, fixed `End` to be correctly handled for mergeX upStreamAsyncRef