Fix drained?. Stop batch read once a nil is read. drained? would previously return true even though values were in the retry channel. This would lead to values after :done on output tasks.
Fix drained?. Stop batch read once a nil is read.
drained? would previously return true even though values were in the
retry channel. This would lead to values after :done on output tasks.

iperdomo/onyx,ideal-knee/onyx,tomasu82/onyx,KevinGreene/onyx,onyx-platform/onyx,vijaykiran/onyx,intfrr/onyx,mccraigmccraig/onyx,dignati/onyx,Deraen/onyx