Public Member Functions | |
SubscriberFactory (NodeIdentifier nodeIdentifier, TopicParticipantManager topicParticipantManager, ScheduledExecutorService executorService) | |
Package Functions | |
public< T > Subscriber< T > | newOrExisting (TopicDeclaration topicDeclaration, MessageDeserializer< T > messageDeserializer) |
Private Attributes | |
final ScheduledExecutorService | executorService |
final Object | mutex |
final NodeIdentifier | nodeIdentifier |
final TopicParticipantManager | topicParticipantManager |
A factory for Subscriber instances.
Definition at line 32 of file SubscriberFactory.java.
org.ros.internal.node.topic.SubscriberFactory.SubscriberFactory | ( | NodeIdentifier | nodeIdentifier, |
TopicParticipantManager | topicParticipantManager, | ||
ScheduledExecutorService | executorService | ||
) | [inline] |
Definition at line 39 of file SubscriberFactory.java.
public<T> Subscriber<T> org.ros.internal.node.topic.SubscriberFactory.newOrExisting | ( | TopicDeclaration | topicDeclaration, |
MessageDeserializer< T > | messageDeserializer | ||
) | [inline, package] |
Gets or creates a Subscriber instance. Subscribers are cached and reused per topic. When a new Subscriber is generated, it is registered with the master.
<T> | the message type associated with the new Subscriber |
topicDeclaration | TopicDeclaration that is subscribed to |
messageDeserializer | the MessageDeserializer to use for incoming messages |
Definition at line 61 of file SubscriberFactory.java.
final ScheduledExecutorService org.ros.internal.node.topic.SubscriberFactory.executorService [private] |
Definition at line 36 of file SubscriberFactory.java.
final Object org.ros.internal.node.topic.SubscriberFactory.mutex [private] |
Definition at line 37 of file SubscriberFactory.java.
Definition at line 34 of file SubscriberFactory.java.
final TopicParticipantManager org.ros.internal.node.topic.SubscriberFactory.topicParticipantManager [private] |
Definition at line 35 of file SubscriberFactory.java.