use super::*; macro_rules! join_with_labels { ($layer:ident<$rt: ident> ($kind:literal, $expr: expr)) => { paste::paste! { #[test] fn [< test_ $rt:snake _ $kind:snake _join_with_labels >]() { [< $rt:snake _run >](async move { memberlist_join_with_labels::<_, QuicTransport]>, _, Lpe<_, _>, [< $rt:camel Runtime >]>, _>(|idx, label| async move { let mut t1_opts = QuicTransportOptions::]>>::with_stream_layer_options(format!("join_with_labels_node_{idx}").into(), $expr). with_label(label); t1_opts.add_bind_address(next_socket_addr_v4(0)); t1_opts }).await; }); } #[cfg(feature = "compression")] #[test] fn [< test_ $rt:snake _ $kind:snake _join_with_labels_with_compression >]() { [< $rt:snake _run >](async move { memberlist_join_with_labels::<_, QuicTransport]>, _, Lpe<_, _>, [< $rt:camel Runtime >]>, _>(|idx, label| async move { let mut t1_opts = QuicTransportOptions::]>>::with_stream_layer_options(format!("join_with_labels_node_{idx}").into(), $expr). with_label(label) .with_compressor(Some(Default::default())); t1_opts.add_bind_address(next_socket_addr_v4(0)); t1_opts }).await; }); } } }; } test_mods!(join_with_labels);