Source code for ebu_tt_live.carriage.direct

from .base import AbstractCombinedCarriage
from ebu_tt_live.utils import ANY


[docs]class DirectCarriageImpl(AbstractCombinedCarriage):

    _expects = ANY
    _provides = ANY

[docs]    def on_new_data(self, data, **kwargs):
        self.producer_node.emit_data(data, **kwargs)

[docs]    def resume_producing(self):
        self.producer_node.resume_producing()

[docs]    def emit_data(self, data, **kwargs):
        self.consumer_node.process_document(data, **kwargs)