'Confirm that all streams are blocked: that is, the priority tree
believes that none of the streams have data ready to send.'

def assertAllStreamsBlocked(self, connection):

    self.assertRaises(priority.DeadlockError, next, connection.priority)
