Mercurial > code > home > repos > light9

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/stubs/cyclone/httpserver.pyi	Thu May 30 08:29:42 2019 +0000
@@ -0,0 +1,43 @@
+# Stubs for cyclone.httpserver (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from twisted.protocols import basic
+from typing import Any, Dict, Optional
+
+class _BadRequestException(Exception): ...
+
+class HTTPConnection(basic.LineReceiver):
+    no_keep_alive: bool = ...
+    content_length: Any = ...
+    request_callback: Any = ...
+    xheaders: Any = ...
+    def connectionMade(self) -> None: ...
+    def connectionLost(self, reason: Any) -> None: ...
+    def notifyFinish(self): ...
+    def lineReceived(self, line: Any) -> None: ...
+    def rawDataReceived(self, data: Any) -> None: ...
+    def write(self, chunk: Any) -> None: ...
+    def finish(self) -> None: ...
+
+class HTTPRequest:
+    method: str = ...
+    uri: str = ...
+    version: str = ...
+    headers: Dict[str, str] = ...
+    body: bytes = ...
+    remote_ip: str = ...
+    protocol: str = ...
+    host: str = ...
+    files: Any = ...
+    connection: HTTPConnection = ...
+    arguments: Any = ...
+    def __init__(self, method: Any, uri: Any, version: str = ..., headers: Optional[Any] = ..., body: Optional[Any] = ..., remote_ip: Optional[Any] = ..., protocol: Optional[Any] = ..., host: Optional[Any] = ..., files: Optional[Any] = ..., connection: Optional[Any] = ...) -> None: ...
+    def supports_http_1_1(self): ...
+    @property
+    def cookies(self): ...
+    def write(self, chunk: Any) -> None: ...
+    def finish(self) -> None: ...
+    def full_url(self): ...
+    def request_time(self): ...
+    def notifyFinish(self): ...
--- a/stubs/cyclone/web.pyi	Wed May 29 15:58:23 2019 +0000
+++ b/stubs/cyclone/web.pyi	Thu May 30 08:29:42 2019 +0000
@@ -3,7 +3,8 @@
 # NOTE: This dynamically typed stub was automatically generated by stubgen.

 from twisted.internet import protocol
-from typing import Any, Optional, List
+from typing import Any, Optional
+from .httpserver import HTTPRequest

 class RequestHandler:
     SUPPORTED_METHODS: Any = ...
@@ -11,11 +12,11 @@
     no_keep_alive: bool = ...
     xsrf_cookie_name: str = ...
     application: Any = ...
-    request: Any = ...
+    request: HTTPRequest = ...
     path_args: Any = ...
     path_kwargs: Any = ...
     ui: Any = ...
-    def __init__(self, application: Any, request: Any, **kwargs: Any) -> None: ...
+    def __init__(self, application: Any, request: HTTPRequest, **kwargs: Any) -> None: ...

     @property
     def settings(self): ...
--- a/stubs/cyclone/websocket.pyi	Wed May 29 15:58:23 2019 +0000
+++ b/stubs/cyclone/websocket.pyi	Thu May 30 08:29:42 2019 +0000
@@ -4,7 +4,7 @@

 import cyclone.escape
 import cyclone.web
-from typing import Any
+from typing import Any, Dict, Union

 class _NotEnoughFrame(Exception): ...

@@ -17,8 +17,8 @@
     def headersReceived(self) -> None: ...
     def connectionMade(self, *args: Any, **kwargs: Any) -> None: ...
     def connectionLost(self, reason: Any) -> None: ...
-    def messageReceived(self, message: Any) -> None: ...
-    def sendMessage(self, message: Any) -> None: ...
+    def messageReceived(self, message: bytes) -> None: ...
+    def sendMessage(self, message: Union[str, Dict]) -> None: ...
     def forbidConnection(self, message: Any): ...

 class WebSocketProtocol:
@@ -28,20 +28,20 @@
     def __init__(self, handler: Any) -> None: ...
     def acceptConnection(self) -> None: ...
     def rawDataReceived(self, data: Any) -> None: ...
-    def sendMessage(self, message: Any) -> None: ...
+    def sendMessage(self, message: Union[str, Dict]) -> None: ...

 class WebSocketProtocol17(WebSocketProtocol):
     def __init__(self, handler: Any) -> None: ...
     def acceptConnection(self) -> None: ...
     def rawDataReceived(self, data: Any) -> None: ...
-    def sendMessage(self, message: Any, code: int = ...) -> None: ...
+    def sendMessage(self, message: Union[str, Dict], code: int = ...) -> None: ...

 class WebSocketProtocol76(WebSocketProtocol):
     def __init__(self, handler: Any) -> None: ...
     def acceptConnection(self) -> None: ...
     def rawDataReceived(self, data: Any) -> None: ...
     def close(self) -> None: ...
-    def sendMessage(self, message: Any) -> None: ...
+    def sendMessage(self, message: Union[str, Dict]) -> None: ...

 class FrameDecodeError(Exception): ...
--- a/stubs/greplin/scales/__init__.pyi	Wed May 29 15:58:23 2019 +0000
+++ b/stubs/greplin/scales/__init__.pyi	Thu May 30 08:29:42 2019 +0000
@@ -126,6 +126,8 @@

 class NamedPmfDictStat(Stat): ...

+class RecentFpsStat(Stat): ...
+
 class StateTimeStatDict(UserDict):
     parent: Any = ...
     instance: Any = ...
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/stubs/twisted/protocols/basic.pyi	Thu May 30 08:29:42 2019 +0000
@@ -0,0 +1,87 @@
+# Stubs for twisted.protocols.basic (Python 3)
+#
+# NOTE: This dynamically typed stub was automatically generated by stubgen.
+
+from twisted.internet import protocol
+from typing import Any, Optional
+
+DEBUG: int
+
+class NetstringParseError(ValueError): ...
+class IncompleteNetstring(Exception): ...
+
+class NetstringReceiver(protocol.Protocol):
+    MAX_LENGTH: int = ...
+    brokenPeer: int = ...
+    def makeConnection(self, transport: Any) -> None: ...
+    def sendString(self, string: Any) -> None: ...
+    def dataReceived(self, data: Any) -> None: ...
+    def stringReceived(self, string: Any) -> None: ...
+
+class LineOnlyReceiver(protocol.Protocol):
+    delimiter: bytes = ...
+    MAX_LENGTH: int = ...
+    def dataReceived(self, data: Any): ...
+    def lineReceived(self, line: Any) -> None: ...
+    def sendLine(self, line: Any): ...
+    def lineLengthExceeded(self, line: Any): ...
+
+class _PauseableMixin:
+    paused: bool = ...
+    def pauseProducing(self) -> None: ...
+    def resumeProducing(self) -> None: ...
+    def stopProducing(self) -> None: ...
+
+class LineReceiver(protocol.Protocol, _PauseableMixin):
+    line_mode: int = ...
+    delimiter: bytes = ...
+    MAX_LENGTH: int = ...
+    def clearLineBuffer(self): ...
+    def dataReceived(self, data: Any): ...
+    def setLineMode(self, extra: bytes = ...): ...
+    def setRawMode(self) -> None: ...
+    def rawDataReceived(self, data: Any) -> None: ...
+    def lineReceived(self, line: Any) -> None: ...
+    def sendLine(self, line: Any): ...
+    def lineLengthExceeded(self, line: Any): ...
+
+class StringTooLongError(AssertionError): ...
+
+class _RecvdCompatHack:
+    def __get__(self, oself: Any, type: Optional[Any] = ...): ...
+
+class IntNStringReceiver(protocol.Protocol, _PauseableMixin):
+    MAX_LENGTH: int = ...
+    recvd: Any = ...
+    def stringReceived(self, string: Any) -> None: ...
+    def lengthLimitExceeded(self, length: Any) -> None: ...
+    def dataReceived(self, data: Any) -> None: ...
+    def sendString(self, string: Any) -> None: ...
+
+class Int32StringReceiver(IntNStringReceiver):
+    structFormat: str = ...
+    prefixLength: Any = ...
+
+class Int16StringReceiver(IntNStringReceiver):
+    structFormat: str = ...
+    prefixLength: Any = ...
+
+class Int8StringReceiver(IntNStringReceiver):
+    structFormat: str = ...
+    prefixLength: Any = ...
+
+class StatefulStringProtocol:
+    state: str = ...
+    def stringReceived(self, string: Any) -> None: ...
+
+class FileSender:
+    CHUNK_SIZE: Any = ...
+    lastSent: str = ...
+    deferred: Any = ...
+    file: Any = ...
+    consumer: Any = ...
+    transform: Any = ...
+    def beginFileTransfer(self, file: Any, consumer: Any, transform: Optional[Any] = ...): ...
+    def resumeProducing(self) -> None: ...
+    def pauseProducing(self) -> None: ...
+    def stopProducing(self) -> None: ...