pending.setdefault(fd, []).extend(split)
except BaseException as ex:
pending_ex = chain_ex(add_ex_tb(ex), pending_ex)
try:
# Try to finish each of the streams
pending.setdefault(fd, []).extend(split)
except BaseException as ex:
pending_ex = chain_ex(add_ex_tb(ex), pending_ex)
try:
# Try to finish each of the streams