Mercurial > code > home > repos > rdfdb

comparison stubs/autobahn/twisted/websocket.pyi @ 64:c1a9403e5d21

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
stubs Ignore-this: d755514360cce384effcd7a78b4657ed
author Drew Perttula <drewp@bigasterisk.com>
date Fri, 31 May 2019 21:39:02 +0000
parents
children
comparison
equal deleted inserted replaced
63:a3718b297d16 64:c1a9403e5d21
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 = ...): ...