[`iota-data-ingestion-core`]: Use CancellationToken
Opened this issue · 0 comments
sergiupopescu199 commented
Description
Currently the IndexerExecutor run method accepts as an argument an oneshot::Receiver<()> to handle graceful shutdown, this is fine but the issue is that some crates use CancellationToken and other use a oneshot channel, to make things compatible it would be better to use the CancellationToken as it can be cloned easily and all tasks which listens to the same CancellationToken can be gracefully shutdown easily.