pub fn subscribed_ports(&mut self) -> HashSet<String> {
    let mut subscribed_ports = HashSet::<String>::new();
    for subs in self.subscriptions.values() {
      subscribed_ports.extend(subs.ports.clone());
    }
    subscribed_ports
  }
/// Get a list of ports that currently have subscriptions
Get a list of ports that currently have subscriptions
Get a list of ports that currently have subscriptions
pub fn subscribed_ports(&mut self) -> HashSet<String> {
    let mut subscribed_ports = HashSet::<String>::new();
    for subs in self.subscriptions.values() {
      subscribed_ports.extend(subs.ports.clone());
    }
    subscribed_ports
  }
pub fn subscribed_ports ( & mut self ) -> HashSet < String > { let mut subscribed_ports = HashSet :: < String > :: new ( ) ; for subs in self . subscriptions . values ( ) { subscribed_ports . extend ( subs . ports . clone ( ) ) ; } subscribed_ports }
Get a list of ports that currently have subscriptions
Get a list of ports that currently have subscriptions
&mut self
&mut self