Source code for gbvision.utils.net.async_tcp_stream_receiver

from .async_stream_receiver import AsyncStreamReceiver
from .tcp_stream_receiver import TCPStreamReceiver


class AsyncTCPStreamReceiver(AsyncStreamReceiver, TCPStreamReceiver):

    def __init__(self, ip, port, *args, **kwargs):
        TCPStreamReceiver.__init__(self, ip, port, *args, **kwargs)
        AsyncStreamReceiver.__init__(self, *args, **kwargs)

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

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