fix: drain loop should not drop buffered messages when ctx is already cancelled

fix: drain loop should not drop buffered messages when ctx is already cancelled #8