main.rs

fn jack_sanity<F>() -> Result<AsyncClient<(), ClosureProcessHandler<F>>, Error>
where
    F: 'static + Send + FnMut(&Client, &ProcessScope) -> Control,
{
    let (client, _status) = Client::new("anal", ClientOptions::NO_START_SERVER)?;

    let in_1 = client.register_port("in_1", AudioIn::default())?;
    let in_2 = client.register_port("in_2", AudioIn::default())?;

    let process_callback = move |_client: &Client, ps: &jack::ProcessScope| -> Control {
        let data_1 = in_1.as_slice(ps);
        let data_2 = in_2.as_slice(ps);

        dbg!(data_1);

        Control::Continue
    };

    let process = ClosureProcessHandler::new(process_callback);

    let active_client = client.activate_async((), process)?;

    Ok(active_client)
}