pub async fn create_messenger_and_publisher_from_hub(
    message_hub: &Delegate<ServicePayload, ServiceAddress, ServiceRole>,
) -> (MessengerClient<ServicePayload, ServiceAddress, ServiceRole>, Publisher) {
    let publisher = Publisher::create(message_hub, MessengerType::Unbound).await;
    let messenger =
        message_hub.create(MessengerType::Unbound).await.expect("Unable to create messenger").0;

    return (messenger, publisher);
}
// Create and return an unbound messenger and publisher from a given `message_hub`.
Create and return an unbound messenger and publisher from a given `message_hub`.
Create and return an unbound messenger and publisher from a given ` message_hub ` .
pub async fn create_messenger_and_publisher_from_hub(
    message_hub: &Delegate<ServicePayload, ServiceAddress, ServiceRole>,
) -> (MessengerClient<ServicePayload, ServiceAddress, ServiceRole>, Publisher) {
    let publisher = Publisher::create(message_hub, MessengerType::Unbound).await;
    let messenger =
        message_hub.create(MessengerType::Unbound).await.expect("Unable to create messenger").0;
    return (messenger, publisher);
}
pub async fn create_messenger_and_publisher_from_hub ( message_hub : & Delegate < ServicePayload , ServiceAddress , ServiceRole > , ) -> ( MessengerClient < ServicePayload , ServiceAddress , ServiceRole > , Publisher ) { let publisher = Publisher :: create ( message_hub , MessengerType :: Unbound ) . await ; let messenger = message_hub . create ( MessengerType :: Unbound ) . await . expect ( " " ) . 0 ; return ( messenger , publisher ) ; }
Create and return an unbound messenger and publisher from a given `message_hub`.
Create and return an unbound messenger and publisher from a given ` message_hub ` .
message_hub
&Delegate<ServicePayload, ServiceAddress, ServiceRole>
message_hub
&Delegate<ServicePayload, ServiceAddress, ServiceRole>