Source code for gbvision.utils.net.async_udp_stream_receiver

from .async_stream_receiver import AsyncStreamReceiver
from .udp_stream_receiver import UDPStreamReceiver


class AsyncUDPStreamReceiver(AsyncStreamReceiver, UDPStreamReceiver):
    def __init__(self, port, *args, **kwargs):
        UDPStreamReceiver.__init__(self, port, *args, **kwargs)
        AsyncStreamReceiver.__init__(self, *args, **kwargs)

    def _read(self):
        return UDPStreamReceiver.read(self)

    def _release(self) -> None:
        UDPStreamReceiver.release(self)