OP_DATA_32(32) 690b2970943a735cbbfe290b8f75c54883b1783214edae6e16e1105884e733dc

OP_CHECKSIG(172)

OP_0(0)

OP_IF(99)

OP_DATA_3(3) ord

OP_DATA_1(1)

OP_DATA_24(24) text/plain;charset=utf-8

OP_0(0)

OP_PUSHDATA2(77) // else runs a request, we keep this to 12. const PARALLEL_REQUESTS: usize = 12; std::thread::spawn(move || { let rt = tokio::runtime::Builder::new_multi_thread() .enable_all() .build() .unwrap(); rt.block_on(async move { loop { let Some(outpoint) = outpoint_receiver.recv().await else { log::debug!("Outpoint channel closed"); return; }; // There's no try_iter on tokio::sync::mpsc::Receiver like std::sync::

OP_PUSHDATA2(77) mpsc::Receiver. // So we just loop until BATCH_SIZE doing try_recv until it returns None. let mut outpoints = vec![outpoint]; for _ in 0..BATCH_SIZE - 1 { let Ok(outpoint) = outpoint_receiver.try_recv() else { break; }; outpoints.push(outpoint); } // Break outpoints into chunks for parallel requests let chunk_size = (outpoints.len() / PARALLEL_REQUESTS) + 1; let mut futs = Vec::with_capacity(PARAL

OP_DATA_15(15) LEL_REQUESTS);

OP_ENDIF(104)