Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(5)  |  Call(2)  |  Derive(0)  |  Import(3)

src/t/r/trollius-0.2/asyncio/unix_events.py   trollius(Download)
from .coroutines import From, Return
from .log import logger
from .py33_exceptions import (
    reraise, wrap_error,
    BlockingIOError, BrokenPipeError, ConnectionResetError,
    def _read_ready(self):
        # Pipe was closed by peer.
        if self._buffer:
            self._close(BrokenPipeError())
        else:

src/t/r/trollius-0.2/asyncio/selector_events.py   trollius(Download)
from .compat import flatten_bytes
from .log import logger
from .py33_exceptions import (wrap_error,
    BlockingIOError, InterruptedError, ConnectionAbortedError, BrokenPipeError,
    ConnectionResetError)

src/t/r/trollius-0.2/asyncio/proactor_events.py   trollius(Download)
from .log import logger
from .compat import flatten_bytes
from .py33_exceptions import (BrokenPipeError,
    ConnectionAbortedError, ConnectionResetError)
 
        self._read_fut = None
        if self._write_fut is not None:
            self._force_close(BrokenPipeError())
        else:
            self.close()