def find_thread_end(buf, (row, col)):
    if LineProperties(buf[row - 1]).is_diffscuss:
        for offset, line in enumerate(buf[row:]):
            if not LineProperties(line).is_diffscuss:
                break
        return row + offset, col
    return row, col
Return the number of messages in a queue.
dataset/ETHPy150Open hut8labs/diffscuss/diffscuss/support/editor.py/find_thread_end--crossover with--dataset/ETHPy150Open celery/kombu/kombu/transport/SLMQ.py/Channel._size