def METHOD_NAME(self, _process_bulk_chunk):
    actions = ({"x": i} for i in range(100))
    list(
        helpers.parallel_bulk(
            Elasticsearch("http://localhost:9200"), actions, chunk_size=2
        )
    )
    assert 50 == mock_process_bulk_chunk.call_count