Source code for pyopendds.Subscriber

from __future__ import annotations
from typing import TYPE_CHECKING, List

from .DataReader import DataReader
from .Topic import Topic
if TYPE_CHECKING:
    from .DomainParticipant import DomainParticipant


class Subscriber:

    def __init__(self, participant: DomainParticipant, qos=None, listener=None):
        participant.subscribers.append(self)
        self.qos = qos
        self.listener = listener
        self.readers: List[DataReader] = []

        from _pyopendds import create_subscriber
        create_subscriber(self, participant)

    def create_datareader(self, topic: Topic, qos=None, listener=None):
        return DataReader(self, topic, qos, listener)