pub async fn new(
        handle: ConductorHandle,
        envs: TestEnvironments,
        config: ConductorConfig,
    ) -> SweetConductor {
        // Automatically add a test app interface
        handle
            .add_test_app_interface(Default::default())
            .await
            .expect("Couldn't set up test app interface");

        // Get a stream of all signals since conductor startup
        let signal_stream = handle.signal_broadcaster().await.subscribe_merged();

        Self {
            handle: Some(SweetConductorHandle(handle)),
            envs,
            config,
            dnas: Vec::new(),
            signal_stream: Some(Box::new(signal_stream)),
        }
    }
/// Create a SweetConductor from an already-built ConductorHandle and environments
///DnaStore
/// The conductor will be supplied with a single test AppInterface named
/// "sweet-interface" so that signals may be emitted
Create a SweetConductor from an already-built ConductorHandle and environments
DnaStore
The conductor will be supplied with a single test AppInterface named
"sweet-interface" so that signals may be emitted
Create a SweetConductor from an already - built ConductorHandle and environments DnaStore The conductor will be supplied with a single test AppInterface named " sweet - interface " so that signals may be emitted
pub async fn new(
        handle: ConductorHandle,
        envs: TestEnvironments,
        config: ConductorConfig,
    ) -> SweetConductor {
        // Automatically add a test app interface
        handle
            .add_test_app_interface(Default::default())
            .await
            .expect("Couldn't set up test app interface");
        // Get a stream of all signals since conductor startup
        let signal_stream = handle.signal_broadcaster().await.subscribe_merged();
        Self {
            handle: Some(SweetConductorHandle(handle)),
            envs,
            config,
            dnas: Vec::new(),
            signal_stream: Some(Box::new(signal_stream)),
        }
    }
pub async fn new ( handle : ConductorHandle , envs : TestEnvironments , config : ConductorConfig , ) -> SweetConductor { // Automatically add a test app interface handle . add_test_app_interface ( Default :: default ( ) ) . await . expect ( " " ) ; // Get a stream of all signals since conductor startup let signal_stream = handle . signal_broadcaster ( ) . await . subscribe_merged ( ) ; Self { handle : Some ( SweetConductorHandle ( handle ) ) , envs , config , dnas : Vec :: new ( ) , signal_stream : Some ( Box :: new ( signal_stream ) ) , } }
Create a SweetConductor from an already-built ConductorHandle and environments
DnaStore
The conductor will be supplied with a single test AppInterface named
"sweet-interface" so that signals may be emitted
Create a SweetConductor from an already - built ConductorHandle and environments DnaStore The conductor will be supplied with a single test AppInterface named " sweet - interface " so that signals may be emitted
handle
ConductorHandle
envs
TestEnvironments
config
ConductorConfig