async fn subscribe_to_signals(client: &NetworkServiceClient) {
    let mut client_id = ClientId::new();
    client_id.id = "rusty_client_sub".to_string();

    let mut subscriber_config = SubscriberConfig::new();
    subscriber_config.clientId = SingularPtrField::some(client_id);
    subscriber_config.signals = generate_signal_ids();

    println!("Subscribing to {:?}", subscriber_config.signals);

    let mut sub_info = client.subscribe_to_signals(&subscriber_config).unwrap();
    while let Some(signals) = sub_info.next().await {
        println!("Received {:?}", signals.unwrap().signal.to_vec())
    }
}
// Create a subscribing stream from set of signalIDs to signal-server
Create a subscribing stream from set of signalIDs to signal-server
Create a subscribing stream from set of signalIDs to signal - server
async fn subscribe_to_signals(client: &NetworkServiceClient) {
    let mut client_id = ClientId::new();
    client_id.id = "rusty_client_sub".to_string();
    let mut subscriber_config = SubscriberConfig::new();
    subscriber_config.clientId = SingularPtrField::some(client_id);
    subscriber_config.signals = generate_signal_ids();
    println!("Subscribing to {:?}", subscriber_config.signals);
    let mut sub_info = client.subscribe_to_signals(&subscriber_config).unwrap();
    while let Some(signals) = sub_info.next().await {
        println!("Received {:?}", signals.unwrap().signal.to_vec())
    }
}
async fn subscribe_to_signals ( client : & NetworkServiceClient ) { let mut client_id = ClientId :: new ( ) ; client_id . id = " " . to_string ( ) ; let mut subscriber_config = SubscriberConfig :: new ( ) ; subscriber_config . clientId = SingularPtrField :: some ( client_id ) ; subscriber_config . signals = generate_signal_ids ( ) ; println ! ( " " subscriber_config signals ) ; let mut sub_info = client . subscribe_to_signals ( & subscriber_config ) . unwrap ( ) ; while let Some ( signals ) = sub_info . next ( ) . await { println ! ( " " signals unwrap ( ) signal to_vec ( ) ) } }
Create a subscribing stream from set of signalIDs to signal-server
Create a subscribing stream from set of signalIDs to signal - server
client
&NetworkServiceClient