pub async fn create_listener(
uri: String,
tx_up: Sender<(String, Option<Sender<ChannelCommand>>)>,
flag_int: Arc<Mutex<bool>>,
) -> Result<()>
Expand description
Create a TCP listener and a upstream channel sender receiver to allow stream/socket identification and registration.