# Stubs for txzmq.req_rep (Python 3)
#
# NOTE: This dynamically typed stub was automatically generated by stubgen.

from txzmq.connection import ZmqConnection
from typing import Any

class ZmqRequestTimeoutError(Exception): ...

class ZmqREQConnection(ZmqConnection):
    socketType: Any = ...
    defaultRequestTimeout: Any = ...
    UUID_POOL_GEN_SIZE: int = ...
    def __init__(self, *args: Any, **kwargs: Any) -> None: ...
    def sendMsg(self, *messageParts: Any, **kwargs: Any): ...
    def messageReceived(self, message: Any) -> None: ...

class ZmqREPConnection(ZmqConnection):
    socketType: Any = ...
    def __init__(self, *args: Any, **kwargs: Any) -> None: ...
    def reply(self, messageId: Any, *messageParts: Any) -> None: ...
    def messageReceived(self, message: Any) -> None: ...
    def gotMessage(self, messageId: Any, *messageParts: Any) -> None: ...

class ZmqXREPConnection(ZmqREPConnection):
    def __init__(self, factory: Any, *endpoints: Any) -> None: ...

class ZmqXREQConnection(ZmqREQConnection):
    def __init__(self, factory: Any, *endpoints: Any) -> None: ...