diff --git a/stubs/autobahn/twisted/websocket.pyi b/stubs/autobahn/twisted/websocket.pyi new file mode 100644 --- /dev/null +++ b/stubs/autobahn/twisted/websocket.pyi @@ -0,0 +1,70 @@ +# Stubs for autobahn.twisted.websocket (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +import twisted.internet.protocol +from autobahn.websocket import protocol +from autobahn.websocket.interfaces import IWebSocketClientAgent +from typing import Any, Optional + +def create_client_agent(reactor: Any): ... + +class _TwistedWebSocketClientAgent(IWebSocketClientAgent): + def __init__(self, reactor: Any) -> None: ... + def open(self, transport_config: Any, options: Any, protocol_class: Optional[Any] = ...): ... + +class WebSocketAdapterProtocol(twisted.internet.protocol.Protocol): + peer: str = ... + log: Any = ... + def connectionMade(self) -> None: ... + def connectionLost(self, reason: Any) -> None: ... + def dataReceived(self, data: Any) -> None: ... + def registerProducer(self, producer: Any, streaming: Any) -> None: ... + def unregisterProducer(self) -> None: ... + +class WebSocketServerProtocol(WebSocketAdapterProtocol, protocol.WebSocketServerProtocol): + log: Any = ... + def get_channel_id(self, channel_id_type: str = ...): ... + +class WebSocketClientProtocol(WebSocketAdapterProtocol, protocol.WebSocketClientProtocol): + log: Any = ... + def startTLS(self) -> None: ... + def get_channel_id(self, channel_id_type: str = ...): ... + +class WebSocketAdapterFactory: ... + +class WebSocketServerFactory(WebSocketAdapterFactory, protocol.WebSocketServerFactory, twisted.internet.protocol.ServerFactory): + reactor: Any = ... + def __init__(self, *args: Any, **kwargs: Any) -> None: ... + +class WebSocketClientFactory(WebSocketAdapterFactory, protocol.WebSocketClientFactory, twisted.internet.protocol.ClientFactory): + reactor: Any = ... + contextFactory: Any = ... + def __init__(self, *args: Any, **kwargs: Any) -> None: ... + +class WrappingWebSocketAdapter: + def onConnect(self, requestOrResponse: Any): ... + def onOpen(self) -> None: ... + def onMessage(self, payload: Any, isBinary: Any) -> None: ... + def onClose(self, wasClean: Any, code: Any, reason: Any) -> None: ... + def write(self, data: Any) -> None: ... + def writeSequence(self, data: Any) -> None: ... + def loseConnection(self) -> None: ... + def getPeer(self): ... + def getHost(self): ... + +class WrappingWebSocketServerProtocol(WrappingWebSocketAdapter, WebSocketServerProtocol): ... +class WrappingWebSocketClientProtocol(WrappingWebSocketAdapter, WebSocketClientProtocol): ... + +class WrappingWebSocketServerFactory(WebSocketServerFactory): + def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ... + def buildProtocol(self, addr: Any): ... + def startFactory(self) -> None: ... + def stopFactory(self) -> None: ... + +class WrappingWebSocketClientFactory(WebSocketClientFactory): + def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ... + def buildProtocol(self, addr: Any): ... + +def connectWS(factory: Any, contextFactory: Optional[Any] = ..., timeout: int = ..., bindAddress: Optional[Any] = ...): ... +def listenWS(factory: Any, contextFactory: Optional[Any] = ..., backlog: int = ..., interface: str = ...): ...