pub async fn init_processor(
rx: Receiver<IPCData>,
global_tx: Sender<IPCData>,
consumer: BaseConsumer,
producer: FutureProducer,
config: CharcoalConfig,
)pub async fn init_processor(
rx: Receiver<IPCData>,
global_tx: Sender<IPCData>,
consumer: BaseConsumer,
producer: FutureProducer,
config: CharcoalConfig,
)