summaryrefslogtreecommitdiffstats
path: root/Lib/asyncio/streams.py
Commit message (Collapse)AuthorAgeFilesLines
* bpo-32262: Fix codestyle; use f-strings formatting where necessary. (#4775)Yury Selivanov2017-12-101-21/+20
|
* bpo-32193: Convert asyncio to async/await usage (#4753)Andrew Svetlov2017-12-081-45/+33
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * Convert asyncio/tasks.py to async/await * Convert asyncio/queues.py to async/await * Convert asyncio/test_utils.py to async/await * Convert asyncio/base_subprocess.py to async/await * Convert asyncio/subprocess.py to async/await * Convert asyncio/streams.py to async/await * Fix comments * Convert asyncio/locks.py to async/await * Convert asyncio.sleep to async def * Add a comment * Add missing news * Convert stubs from AbstrctEventLoop to async functions * Convert subprocess_shell/subprocess_exec * Convert connect_read_pipe/connect_write_pip to async/await syntax * Convert create_datagram_endpoint * Convert create_unix_server/create_unix_connection * Get rid of old style coroutines in unix_events.py * Convert selector_events.py to async/await * Convert wait_closed and create_connection * Drop redundant line * Convert base_events.py * Code cleanup * Drop redundant comments * Fix indentation * Add explicit tests for compatibility between old and new coroutines * Convert windows event loop to use async/await * Fix double awaiting of async function * Convert asyncio/locks.py * Improve docstring * Convert tests to async/await * Convert more tests * Convert more tests * Convert more tests * Convert tests * Improve test
* Fix asyncio.streams.FlowControlMixin docstring typo. (#4578)John Chen2017-12-011-1/+1
|
* asyncio: Remove asyncio/compat.py (#4606)Victor Stinner2017-11-281-1/+0
| | | | | | | | | | The asyncio/compat.py file was written to support Python < 3.5 and Python < 3.5.2. But Python 3.5 doesn't accept bugfixes anymore, only security fixes. There is no more need to backport bugfixes to Python 3.5, and so no need to have a single code base for Python 3.5, 3.6 and 3.7. Say hello (again) to "async" and "await", who became real keywords in Python 3.7 ;-)
* bpo-32034: Make IncompleteReadError & LimitOverrunError pickleable #4409Yury Selivanov2017-11-151-0/+6
|
* bpo-31709: Drop support for asynchronous __aiter__. (#3903)Yury Selivanov2017-10-061-17/+9
|
* Issue #28370: Speedup asyncio.StreamReader.readexactlyYury Selivanov2016-10-051-19/+17
| | | | Patch by Коренберг Марк.
* Issue #27895: Spelling fixes (Contributed by Ville Skyttä).Martin Panter2016-09-071-1/+1
|
* Issue #27243: Fix __aiter__ protocolYury Selivanov2016-06-091-0/+6
|
* asyncio: Fix an SSL warning in StreamReaderProtocol.eof_receivedYury Selivanov2016-05-201-0/+7
|
* asyncio/streams: Fix code style; delete LimitOverrunError.message attrYury Selivanov2016-05-161-33/+34
|
* Issue #27041: asyncio: Add loop.create_future methodYury Selivanov2016-05-161-2/+2
|
* asyncio: Break reference cycle in StreamReaderProtocol.connection_lostYury Selivanov2016-05-131-4/+7
|
* Issue #26050: Add asyncio.StreamReader.readuntil() method.Yury Selivanov2016-01-111-38/+187
| | | | Patch by Марк Коренберг.
* asyncio: Sync with githubYury Selivanov2015-12-111-0/+3
|
* asyncio: Add Transport.is_closing()Yury Selivanov2015-11-161-1/+1
| | | | See https://github.com/python/asyncio/pull/291 for details.
* Issue #25523: Correct "a" article to "an" articleMartin Panter2015-11-021-1/+1
| | | | | | This changes the main documentation, doc strings, source code comments, and a couple error messages in the test suite. In some cases the word was removed or edited some other way to fix the grammar.
* Issue #25441: asyncio: Raise error from drain() when socket is closed.Guido van Rossum2015-10-191-0/+9
|
* Fix StreamReader.__repr__Andrew Svetlov2015-09-291-1/+1
|
* asyncio: sync with githubVictor Stinner2015-07-251-1/+19
| | | | | | | | | * Fix ResourceWarning warnings in test_streams * Return True from StreamReader.eof_received() to fix http://bugs.python.org/issue24539 (but still needs a unittest). Add StreamReader.__repr__() for easy debugging. * remove unused imports * Issue #234: Drop JoinableQueue on Python 3.5+
* asyncio: Add asyncio.compat moduleVictor Stinner2015-07-251-2/+2
| | | | | Move compatibility helpers for the different Python versions to a new asyncio.compat module.
* Sync asyncio code from default branch.Yury Selivanov2015-05-131-0/+14
|
* Issue #23456: Add missing @coroutine decorators in asyncioVictor Stinner2015-03-181-0/+1
|
* Backout changeset 6ab2575bc12bVictor Stinner2015-01-151-21/+4
| | | | | | | StreamWriter: close() now clears the reference to the transport StreamWriter now raises an exception if it is closed: write(), writelines(), write_eof(), can_write_eof(), get_extra_info(), drain().
* StreamWriter: close() now clears the reference to the transportVictor Stinner2015-01-151-4/+21
| | | | | StreamWriter now raises an exception if it is closed: write(), writelines(), write_eof(), can_write_eof(), get_extra_info(), drain().
* Issue #23198: Reactor asyncio.StreamReaderVictor Stinner2015-01-131-25/+22
| | | | | | - Add a new _wakeup_waiter() method - Replace _create_waiter() method with a _wait_for_data() coroutine function - Use the value None instead of True or False to wake up the waiter
* asyncio: sync with TulipVictor Stinner2015-01-091-3/+7
| | | | | | | * Tulip issue 184: FlowControlMixin constructor now get the event loop if the loop parameter is not set. Add unit tests to ensure that constructor of StreamReader and StreamReaderProtocol classes get the event loop. * Remove outdated TODO/XXX
* asyncio, tulip issue 193: Convert StreamWriter.drain() to a classic coroutineVictor Stinner2014-07-221-19/+18
| | | | | Replace also _make_drain_waiter() function with a classic _drain_helper() coroutine.
* asyncio: sync with TulipVictor Stinner2014-07-141-0/+12
| | | | | | | | | | | | | | | | | | | | * Tulip issue #184: Log subprocess events in debug mode - Log stdin, stdout and stderr transports and protocols - Log process identifier (pid) - Log connection of pipes - Log process exit - Log Process.communicate() tasks: feed stdin, read stdout and stderr - Add __repr__() method to many classes related to subprocesses * Add BaseSubprocessTransport._pid attribute. Store the pid so it is still accessible after the process exited. It's more convinient for debug. * create_connection(): add the socket in the "connected to" debug log * Clean up some docstrings and comments. Remove unused unimplemented _read_from_self().
* asyncio: sync with TulipVictor Stinner2014-07-111-1/+0
| | | | | | | | | | * Tulip issue #182: Improve logs of BaseEventLoop._run_once() - Don't log non-blocking poll - Only log polling with a timeout if it gets events or if it timed out after more than 1 second. * Fix some pyflakes warnings: remove unused imports
* asyncio: sync with TulipVictor Stinner2014-07-081-1/+1
| | | | | | | | | | | - Tulip issue 185: Add a create_task() method to event loops. The create_task() method can be overriden in custom event loop to implement their own task class. For example, greenio and Pulsar projects use their own task class. The create_task() method is now preferred over creating directly task using the Task class. - tests: fix a warning - fix typo in the name of a test function - Update AbstractEventLoop: add new event loop methods; update also the unit test
* asyncio: sync with Tulip, add a new asyncio.coroutines moduleVictor Stinner2014-06-281-8/+10
|
* asyncio: Fix upstream issue 168: StreamReader.read(-1) from pipe may hang if ↵Guido van Rossum2014-05-121-6/+11
| | | | data exceeds buffer limit.
* asyncio: Make tests pass on Windows.Guido van Rossum2014-02-181-1/+3
|
* asyncio: Add support for UNIX Domain Sockets.Yury Selivanov2014-02-181-1/+38
|
* asyncio.streams.StreamReader: Add 'at_eof()' methodYury Selivanov2014-02-061-0/+4
|
* asyncio.streams: Use bytebuffer in StreamReader; Add assertion in feed_dataYury Selivanov2014-02-051-49/+24
|
* asyncio: Fix misc whitespace issues.Guido van Rossum2014-01-311-0/+1
|
* asyncio: Refactor drain logic in streams.py to be reusable.Guido van Rossum2014-01-291-36/+61
|
* Update asyncio from the Tulip projectVictor Stinner2014-01-251-6/+16
| | | | | | | | | | | | | | | | Major changes: - StreamReader.readexactly() now raises an IncompleteReadError if the end of stream is reached before we received enough bytes, instead of returning less bytes than requested. - Unit tests use the main asyncio module instead of submodules like events - _UnixWritePipeTransport now also supports character devices, as _UnixReadPipeTransport. Patch written by Jonathan Slenders. - Export more symbols: BaseEventLoop, BaseProactorEventLoop, BaseSelectorEventLoop, Queue and Queue sublasses, Empty, Full
* asyncio (Tulip issue 110): StreamReader.read() and StreamReader.readline() nowVictor Stinner2014-01-231-7/+14
| | | | | raise a RuntimeError, instead of using an assertion, if another coroutine is already waiting for incoming data
* asyncio: Fix open_connection() documentation, writer is a StreamWriterVictor Stinner2014-01-231-1/+1
|
* asyncio: Tiny cleanup in streams.py.Guido van Rossum2014-01-101-2/+2
|
* Fix typo in asyncio/streams.py.Guido van Rossum2014-01-081-1/+1
|
* asyncio: Fix deadlock in readexactly(). Fixes issue #20154.Guido van Rossum2014-01-071-10/+19
|
* asyncio: Add StreamReaderProtocol to __all__.Guido van Rossum2013-11-251-1/+1
|
* asyncio: Add streams.start_server(), by Gustavo Carneiro.Guido van Rossum2013-11-191-2/+51
|
* Write flow control for asyncio (includes asyncio.streams overhaul).Guido van Rossum2013-10-181-58/+150
|
* Rename Transport.pause/resume to pause_reading/pause_writing. Also relax ↵Guido van Rossum2013-10-181-2/+2
| | | | timeout in test_call_later().
* Initial checkin of asyncio package (== Tulip, == PEP 3156).Guido van Rossum2013-10-171-0/+257
generated by cgit v0.12 at 2025-08-14 15:20:30 (GMT)