You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: mod.rs
    path of file: ./repos/fluvio/crates/fluvio-test/src/tests/concurrent
    
    the code of the file until where you have to start completion: pub mod producer;
pub mod consumer;
pub mod util;

use clap::Parser;

use fluvio_future::task::spawn;
use fluvio_test_derive::fluvio_test;
use fluvio_test_case_derive::MyTestCase;
use fluvio_future::task::run_block_on;

#[derive(Debug, Clone, Parser, Default, Eq, PartialEq, MyTestCase)]
#[command(name = "Fluvio Concurrent Test")]
pub struct ConcurrentTestOption {}


    
pub fn concurrent(mut test_driver: TestDriver, mut test_case: TestCase) {
    println!("Testing concurrent consumer and producer");
    let option: MyTestCase = test_case.into();

    run_block_on(async {
        let (sender, receiver) = std::sync::mpsc::channel();
        spawn(consumer::consumer_stream(
            test_driver.clone(),
            option.clone(),
            receiver,
        ));
        producer::producer(&test_driver, option, sender).await;
    });
}