pub fn create_publisher(
    &self,
    domain_participant: &DomainParticipantWeak,
    qos: &QosPolicies,
    discovery_command: mio_channel::SyncSender<DiscoveryCommand>,
  ) -> Result<Publisher> {
    Ok(Publisher::new(
      domain_participant.clone(),
      self.discovery_db.clone(),
      qos.clone(),
      qos.clone(),
      self.add_writer_sender.clone(),
      discovery_command,
    ))
  }
// Publisher and subscriber creation
//
// There are no delete function for publisher or subscriber. Deletion is performed by
// deleting the Publisher or Subscriber object, who upon deletion will notify
// the DomainParticipant.
Publisher and subscriber creation
There are no delete function for publisher or subscriber. Deletion is performed by
deleting the Publisher or Subscriber object, who upon deletion will notify
the DomainParticipant.
Publisher and subscriber creation There are no delete function for publisher or subscriber . Deletion is performed by deleting the Publisher or Subscriber object who upon deletion will notify the DomainParticipant .
pub fn create_publisher(
    &self,
    domain_participant: &DomainParticipantWeak,
    qos: &QosPolicies,
    discovery_command: mio_channel::SyncSender<DiscoveryCommand>,
  ) -> Result<Publisher> {
    Ok(Publisher::new(
      domain_participant.clone(),
      self.discovery_db.clone(),
      qos.clone(),
      qos.clone(),
      self.add_writer_sender.clone(),
      discovery_command,
    ))
  }
pub fn create_publisher ( & self , domain_participant : & DomainParticipantWeak , qos : & QosPolicies , discovery_command : mio_channel :: SyncSender < DiscoveryCommand > , ) -> Result < Publisher > { Ok ( Publisher :: new ( domain_participant . clone ( ) , self . discovery_db . clone ( ) , qos . clone ( ) , qos . clone ( ) , self . add_writer_sender . clone ( ) , discovery_command , ) ) }
Publisher and subscriber creation
There are no delete function for publisher or subscriber.
Publisher and subscriber creation There are no delete function for publisher or subscriber .
&self
domain_participant
&DomainParticipantWeak
qos
&QosPolicies
discovery_command
mio_channel::SyncSender<DiscoveryCommand>