Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
send_ready
def send_ready(reader, conn, count):
if (reader.total_ready_count + count) > reader.max_in_flight:
return
conn.send_ready(count)
conn.rdy_count = count
reader.total_ready_count += count
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment