|
64
|
1 # Stubs for autobahn.twisted.websocket (Python 3)
|
|
|
2 #
|
|
|
3 # NOTE: This dynamically typed stub was automatically generated by stubgen.
|
|
|
4
|
|
|
5 import twisted.internet.protocol
|
|
|
6 from autobahn.websocket import protocol
|
|
|
7 from autobahn.websocket.interfaces import IWebSocketClientAgent
|
|
|
8 from typing import Any, Optional
|
|
|
9
|
|
|
10 def create_client_agent(reactor: Any): ...
|
|
|
11
|
|
|
12 class _TwistedWebSocketClientAgent(IWebSocketClientAgent):
|
|
|
13 def __init__(self, reactor: Any) -> None: ...
|
|
|
14 def open(self, transport_config: Any, options: Any, protocol_class: Optional[Any] = ...): ...
|
|
|
15
|
|
|
16 class WebSocketAdapterProtocol(twisted.internet.protocol.Protocol):
|
|
|
17 peer: str = ...
|
|
|
18 log: Any = ...
|
|
|
19 def connectionMade(self) -> None: ...
|
|
|
20 def connectionLost(self, reason: Any) -> None: ...
|
|
|
21 def dataReceived(self, data: Any) -> None: ...
|
|
|
22 def registerProducer(self, producer: Any, streaming: Any) -> None: ...
|
|
|
23 def unregisterProducer(self) -> None: ...
|
|
|
24
|
|
|
25 class WebSocketServerProtocol(WebSocketAdapterProtocol, protocol.WebSocketServerProtocol):
|
|
|
26 log: Any = ...
|
|
|
27 def get_channel_id(self, channel_id_type: str = ...): ...
|
|
|
28
|
|
|
29 class WebSocketClientProtocol(WebSocketAdapterProtocol, protocol.WebSocketClientProtocol):
|
|
|
30 log: Any = ...
|
|
|
31 def startTLS(self) -> None: ...
|
|
|
32 def get_channel_id(self, channel_id_type: str = ...): ...
|
|
|
33
|
|
|
34 class WebSocketAdapterFactory: ...
|
|
|
35
|
|
|
36 class WebSocketServerFactory(WebSocketAdapterFactory, protocol.WebSocketServerFactory, twisted.internet.protocol.ServerFactory):
|
|
|
37 reactor: Any = ...
|
|
|
38 def __init__(self, *args: Any, **kwargs: Any) -> None: ...
|
|
|
39
|
|
|
40 class WebSocketClientFactory(WebSocketAdapterFactory, protocol.WebSocketClientFactory, twisted.internet.protocol.ClientFactory):
|
|
|
41 reactor: Any = ...
|
|
|
42 contextFactory: Any = ...
|
|
|
43 def __init__(self, *args: Any, **kwargs: Any) -> None: ...
|
|
|
44
|
|
|
45 class WrappingWebSocketAdapter:
|
|
|
46 def onConnect(self, requestOrResponse: Any): ...
|
|
|
47 def onOpen(self) -> None: ...
|
|
|
48 def onMessage(self, payload: Any, isBinary: Any) -> None: ...
|
|
|
49 def onClose(self, wasClean: Any, code: Any, reason: Any) -> None: ...
|
|
|
50 def write(self, data: Any) -> None: ...
|
|
|
51 def writeSequence(self, data: Any) -> None: ...
|
|
|
52 def loseConnection(self) -> None: ...
|
|
|
53 def getPeer(self): ...
|
|
|
54 def getHost(self): ...
|
|
|
55
|
|
|
56 class WrappingWebSocketServerProtocol(WrappingWebSocketAdapter, WebSocketServerProtocol): ...
|
|
|
57 class WrappingWebSocketClientProtocol(WrappingWebSocketAdapter, WebSocketClientProtocol): ...
|
|
|
58
|
|
|
59 class WrappingWebSocketServerFactory(WebSocketServerFactory):
|
|
|
60 def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ...
|
|
|
61 def buildProtocol(self, addr: Any): ...
|
|
|
62 def startFactory(self) -> None: ...
|
|
|
63 def stopFactory(self) -> None: ...
|
|
|
64
|
|
|
65 class WrappingWebSocketClientFactory(WebSocketClientFactory):
|
|
|
66 def __init__(self, factory: Any, url: Any, reactor: Optional[Any] = ..., enableCompression: bool = ..., autoFragmentSize: int = ..., subprotocol: Optional[Any] = ...) -> None: ...
|
|
|
67 def buildProtocol(self, addr: Any): ...
|
|
|
68
|
|
|
69 def connectWS(factory: Any, contextFactory: Optional[Any] = ..., timeout: int = ..., bindAddress: Optional[Any] = ...): ...
|
|
|
70 def listenWS(factory: Any, contextFactory: Optional[Any] = ..., backlog: int = ..., interface: str = ...): ...
|
