pub

class cyclonedds.pub.Publisher(domain_participant, qos=None, listener=None)

Bases: cyclonedds.core.Entity

Parameters

• domain_participant (cyclonedds.domain.DomainParticipant) –

• qos (Optional[cyclonedds.qos.Qos]) –

• listener (Optional[cyclonedds.core.Listener]) –

suspend()

resume()

wait_for_acks(timeout)

Parameters

timeout (int) –

class cyclonedds.pub.DataWriter(publisher_or_participant, topic, qos=None, listener=None)

Bases: cyclonedds.core.Entity, Generic[cyclonedds.pub._T]

Parameters

• publisher_or_participant (Union[cyclonedds.domain.DomainParticipant, cyclonedds.pub.Publisher]) –

• topic (cyclonedds.topic.Topic[cyclonedds.pub._T]) –

• qos (Optional[cyclonedds.qos.Qos]) –

• listener (Optional[cyclonedds.core.Listener]) –

property topic: cyclonedds.topic.Topic[cyclonedds.pub._T]

write(sample, timestamp=None)

Parameters

• sample (cyclonedds.pub._T) –

• timestamp (Optional[int]) –

write_dispose(sample, timestamp=None)

Parameters

• sample (cyclonedds.pub._T) –

• timestamp (Optional[int]) –

dispose(sample, timestamp=None)

Parameters

• sample (cyclonedds.pub._T) –

• timestamp (Optional[int]) –

dispose_instance_handle(handle, timestamp=None)

Parameters

• handle (int) –

• timestamp (Optional[int]) –

register_instance(sample)

Parameters

sample (cyclonedds.pub._T) –

Return type

int

unregister_instance(sample, timestamp=None)

Parameters

• sample (cyclonedds.pub._T) –

• timestamp (Optional[int]) –

unregister_instance_handle(handle, timestamp=None)

Parameters

• handle (int) –

• timestamp (Optional[int]) –

wait_for_acks(timeout)

Parameters

timeout (int) –

Return type

bool

lookup_instance(sample)

Parameters

sample (cyclonedds.pub._T) –

Return type

Optional[int]