diff --git a/stubs/twisted/internet/defer.pyi b/stubs/twisted/internet/defer.pyi new file mode 100644 --- /dev/null +++ b/stubs/twisted/internet/defer.pyi @@ -0,0 +1,124 @@ +# Stubs for twisted.internet.defer (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from twisted.python import lockfile +from typing import Any, Callable, Generic, Optional, TypeVar + +class AlreadyCalledError(Exception): ... +class CancelledError(Exception): ... +class TimeoutError(Exception): ... + +def succeed(result: Any): ... +def fail(result: Optional[Any] = ...): ... +def maybeDeferred(f: Any, *args: Any, **kw: Any): ... + +T = TypeVar('T') +class Deferred(Generic[T]): + called: bool = ... + paused: bool = ... + debug: bool = ... + callbacks: Any = ... + def __init__(self, canceller: Optional[Any] = ...) -> None: ... + def addCallbacks(self, + callback: Callable[[T], Any], + errback: Optional[Any] = ..., + callbackArgs: Optional[Any] = ..., + callbackKeywords: Optional[Any] = ..., + errbackArgs: Optional[Any] = ..., + errbackKeywords: Optional[Any] = ...): ... + def addCallback(self, callback: Callable[[T], Any], *args: Any, **kw: Any): ... + def addErrback(self, errback: Any, *args: Any, **kw: Any): ... + def addBoth(self, callback: Callable[[T], Any], *args: Any, **kw: Any): ... + def addTimeout(self, timeout: Any, clock: Any, onTimeoutCancel: Optional[Any] = ...): ... + def chainDeferred(self, d: Any): ... + def callback(self, result: T) -> None: ... + def errback(self, fail: Optional[Any] = ...) -> None: ... + def pause(self) -> None: ... + def unpause(self) -> None: ... + def cancel(self) -> None: ... + def __iter__(self): ... + def send(self, value: Optional[Any] = ...): ... + __await__: Any = ... + __next__: Any = ... + def asFuture(self, loop: Any): ... + @classmethod + def fromFuture(cls, future: Any): ... + +def ensureDeferred(coro: Any): ... + +class DebugInfo: + failResult: Any = ... + def __del__(self) -> None: ... + +class FirstError(Exception): + subFailure: Any = ... + index: Any = ... + def __init__(self, failure: Any, index: Any) -> None: ... + def __cmp__(self, other: Any): ... + +class DeferredList(Deferred): + fireOnOneCallback: bool = ... + fireOnOneErrback: bool = ... + resultList: Any = ... + consumeErrors: Any = ... + finishedCount: int = ... + def __init__(self, deferredList: Any, fireOnOneCallback: bool = ..., fireOnOneErrback: bool = ..., consumeErrors: bool = ...) -> None: ... + def cancel(self) -> None: ... + +def gatherResults(deferredList: Any, consumeErrors: bool = ...): ... + +SUCCESS: bool +FAILURE: bool + +class waitForDeferred: + d: Any = ... + def __init__(self, d: Any) -> None: ... + def getResult(self): ... + +def deferredGenerator(f: Any): ... + +class _DefGen_Return(BaseException): + value: Any = ... + def __init__(self, value: Any) -> None: ... + +def returnValue(val: Any) -> None: ... + +class _InternalInlineCallbacksCancelledError(Exception): ... + +def inlineCallbacks(f: Any): ... + +class _ConcurrencyPrimitive: + waiting: Any = ... + def __init__(self) -> None: ... + def run(*args: Any, **kwargs: Any): ... + +class DeferredLock(_ConcurrencyPrimitive): + locked: bool = ... + def acquire(self): ... + def release(self) -> None: ... + +class DeferredSemaphore(_ConcurrencyPrimitive): + tokens: Any = ... + limit: Any = ... + def __init__(self, tokens: Any) -> None: ... + def acquire(self): ... + def release(self) -> None: ... + +class QueueOverflow(Exception): ... +class QueueUnderflow(Exception): ... + +class DeferredQueue: + waiting: Any = ... + pending: Any = ... + size: Any = ... + backlog: Any = ... + def __init__(self, size: Optional[Any] = ..., backlog: Optional[Any] = ...) -> None: ... + def put(self, obj: Any) -> None: ... + def get(self): ... + +class AlreadyTryingToLockError(Exception): ... + +class DeferredFilesystemLock(lockfile.FilesystemLock): + def __init__(self, name: Any, scheduler: Optional[Any] = ...) -> None: ... + def deferUntilLocked(self, timeout: Optional[Any] = ...): ...