.config/coc/extensions/coc-python-data/languageServer.0.5.59/Typeshed/stdlib/3.4/asyncio/queues.pyi

   1 import sys\r
   2 from asyncio.events import AbstractEventLoop\r
   3 from .coroutines import coroutine\r
   4 from .futures import Future\r
   5 from typing import Any, Generator, Generic, List, TypeVar\r
   6 \r
   7 __all__: List[str]\r
   8 \r
   9 \r
  10 class QueueEmpty(Exception): ...\r
  11 class QueueFull(Exception): ...\r
  12 \r
  13 _T = TypeVar('_T')\r
  14 \r
  15 class Queue(Generic[_T]):\r
  16     def __init__(self, maxsize: int = ..., *, loop: AbstractEventLoop = ...) -> None: ...\r
  17     def _init(self, maxsize: int) -> None: ...\r
  18     def _get(self) -> _T: ...\r
  19     def _put(self, item: _T) -> None: ...\r
  20     def __repr__(self) -> str: ...\r
  21     def __str__(self) -> str: ...\r
  22     def _format(self) -> str: ...\r
  23     def _consume_done_getters(self) -> None: ...\r
  24     def _consume_done_putters(self) -> None: ...\r
  25     def qsize(self) -> int: ...\r
  26     @property\r
  27     def maxsize(self) -> int: ...\r
  28     def empty(self) -> bool: ...\r
  29     def full(self) -> bool: ...\r
  30     @coroutine\r
  31     def put(self, item: _T) -> Generator[Any, None, None]: ...\r
  32     def put_nowait(self, item: _T) -> None: ...\r
  33     @coroutine\r
  34     def get(self) -> Generator[Any, None, _T]: ...\r
  35     def get_nowait(self) -> _T: ...\r
  36     if sys.version_info >= (3, 4):\r
  37         @coroutine\r
  38         def join(self) -> Generator[Any, None, bool]: ...\r
  39         def task_done(self) -> None: ...\r
  40 \r
  41 \r
  42 class PriorityQueue(Queue[_T]): ...\r
  43 \r
  44 \r
  45 class LifoQueue(Queue[_T]): ...\r
  46 \r
  47 if sys.version_info < (3, 5):\r
  48     class JoinableQueue(Queue[_T]):\r
  49         def task_done(self) -> None: ...\r
  50         @coroutine\r
  51         def join(self) -> Generator[Any, None, bool]: ...\r