Documentation for eth_defi.event_reader.reader.extract_events_concurrent function.

extract_events_concurrent(start_block, end_block, filter, context=None, extract_timestamps=<function extract_timestamps_json_rpc>)[source]

Concurrency happy event extractor.

You should use read_events_concurrent() unless you know the block range is something your node can handle.

Called by the thread pool - you probably do not want to call this directly.

Assumes the web3 connection is preset when the concurrent worker has been created, see get_worker_web3().

Return type