summaryrefslogtreecommitdiff
path: root/asyncio/streams.py
Commit message (Collapse)AuthorAgeFilesLines
* Backout changeset 3a06020af8cfVictor 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().
* Python issue #23198: Reactor StreamReaderVictor Stinner2015-01-141-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
* Tulip issue #184: FlowControlMixin constructor now get the event loop if theVictor Stinner2015-01-091-3/+7
| | | | | | | loop parameter is not set Add unit tests to ensure that constructor of StreamReader and StreamReaderProtocol classes get the event loop.
* 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.
* Tulip issue #184: Log subprocess events in debug modeVictor Stinner2014-07-141-0/+12
| | | | | | | | | - 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
* Fix some pyflakes warnings: remove unused importsVictor Stinner2014-07-111-1/+0
|
* Tulip issue #185: Add a create_task() method to event loopsVictor Stinner2014-07-081-1/+1
| | | | | | | | | 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.
* Backed out changeset b288da71fb40Victor Stinner2014-07-031-1/+1
| | | | Oops, I wanted to send this patch for review before
* Add asyncio.tasks.task_factory variableVictor Stinner2014-07-031-1/+1
| | | | | | | In the greenio project, Task._step() should not create Task objects but GreenTask to control how tasks are executed. Luca Sbardella already asked this feature for its Pulsar project to support coroutines using yield instead of yield-from.
* Move coroutine code in the new module asyncio.coroutinesVictor Stinner2014-06-291-8/+10
|
* Fix issue 168: StreamReader.read(-1) from pipe may hang if data exceeds ↵Guido van Rossum2014-05-121-6/+11
| | | | buffer limit.
* Only add *_unix_* to __all__ if they are defined.Guido van Rossum2014-02-181-1/+3
|
* Add support for UNIX Domain Sockets. Closes issue #81.Yury Selivanov2014-02-181-1/+38
| | | | | | | | | New APIs: - loop.create_unix_connection - loop.create_unix_server - streams.open_unix_connection - streams.start_unix_server
* streams.StreamReader: Add 'at_eof()' methodYury Selivanov2014-02-061-0/+4
|
* streams.StreamReader.feed_data: Add assertion that stream is not in EOF stateYury Selivanov2014-02-051-0/+2
|
* streams.StreamReader: Use bytearray instead of deque of bytes for internal ↵Yury Selivanov2014-02-041-49/+22
| | | | buffer
* Normalize whitespace (use "make pep8" to verify).Guido van Rossum2014-01-301-0/+1
|
* Refactor drain logic in streams.py to be reusable.Guido van Rossum2014-01-281-36/+61
|
* Issue #111: StreamReader.readexactly() now raises an IncompleteReadError if theVictor Stinner2014-01-241-6/+16
| | | | | end of stream is reached before we received enough bytes, instead of returning less bytes than requested.
* Issue #110: StreamReader.read() and StreamReader.readline() now raise aVictor Stinner2014-01-231-6/+13
| | | | | RuntimeError, instead of using an assertion, if another coroutine is already waiting for incoming data
* Fix open_connection() docstring, writer is a StreamWriterVictor Stinner2014-01-231-1/+1
|
* Tiny tweaks to code/docs.Guido van Rossum2014-01-091-2/+2
|
* Fix the fix I just committed. :-(Guido van Rossum2014-01-071-1/+1
|
* Fix typo (_writer instead of _reader).Guido van Rossum2014-01-071-1/+1
|
* Avoid pause deadlock in readexactly(). Fixes issue 99.Guido van Rossum2014-01-061-10/+19
|
* Add StreamReaderProtocol to __all__.Guido van Rossum2013-11-251-1/+1
|
* Add streams.start_server(), by Gustavo Carneiro.Guido van Rossum2013-11-191-2/+51
|
* Bulk mergeGuido van Rossum2013-10-181-58/+150
|
* MergeGuido van Rossum2013-10-181-2/+2
|
* Rename tulip package to asyncio.Guido van Rossum2013-10-141-0/+257