Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Backout changeset 3a06020af8cf | Victor Stinner | 2015-01-15 | 1 | -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 transport | Victor Stinner | 2015-01-15 | 1 | -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 StreamReader | Victor Stinner | 2015-01-14 | 1 | -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 the | Victor Stinner | 2015-01-09 | 1 | -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 coroutine | Victor Stinner | 2014-07-22 | 1 | -19/+18 |
| | | | | | Replace also _make_drain_waiter() function with a classic _drain_helper() coroutine. | ||||
* | Tulip issue #184: Log subprocess events in debug mode | Victor Stinner | 2014-07-14 | 1 | -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 imports | Victor Stinner | 2014-07-11 | 1 | -1/+0 |
| | |||||
* | Tulip issue #185: Add a create_task() method to event loops | Victor Stinner | 2014-07-08 | 1 | -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 b288da71fb40 | Victor Stinner | 2014-07-03 | 1 | -1/+1 |
| | | | | Oops, I wanted to send this patch for review before | ||||
* | Add asyncio.tasks.task_factory variable | Victor Stinner | 2014-07-03 | 1 | -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.coroutines | Victor Stinner | 2014-06-29 | 1 | -8/+10 |
| | |||||
* | Fix issue 168: StreamReader.read(-1) from pipe may hang if data exceeds ↵ | Guido van Rossum | 2014-05-12 | 1 | -6/+11 |
| | | | | buffer limit. | ||||
* | Only add *_unix_* to __all__ if they are defined. | Guido van Rossum | 2014-02-18 | 1 | -1/+3 |
| | |||||
* | Add support for UNIX Domain Sockets. Closes issue #81. | Yury Selivanov | 2014-02-18 | 1 | -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()' method | Yury Selivanov | 2014-02-06 | 1 | -0/+4 |
| | |||||
* | streams.StreamReader.feed_data: Add assertion that stream is not in EOF state | Yury Selivanov | 2014-02-05 | 1 | -0/+2 |
| | |||||
* | streams.StreamReader: Use bytearray instead of deque of bytes for internal ↵ | Yury Selivanov | 2014-02-04 | 1 | -49/+22 |
| | | | | buffer | ||||
* | Normalize whitespace (use "make pep8" to verify). | Guido van Rossum | 2014-01-30 | 1 | -0/+1 |
| | |||||
* | Refactor drain logic in streams.py to be reusable. | Guido van Rossum | 2014-01-28 | 1 | -36/+61 |
| | |||||
* | Issue #111: StreamReader.readexactly() now raises an IncompleteReadError if the | Victor Stinner | 2014-01-24 | 1 | -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 a | Victor Stinner | 2014-01-23 | 1 | -6/+13 |
| | | | | | RuntimeError, instead of using an assertion, if another coroutine is already waiting for incoming data | ||||
* | Fix open_connection() docstring, writer is a StreamWriter | Victor Stinner | 2014-01-23 | 1 | -1/+1 |
| | |||||
* | Tiny tweaks to code/docs. | Guido van Rossum | 2014-01-09 | 1 | -2/+2 |
| | |||||
* | Fix the fix I just committed. :-( | Guido van Rossum | 2014-01-07 | 1 | -1/+1 |
| | |||||
* | Fix typo (_writer instead of _reader). | Guido van Rossum | 2014-01-07 | 1 | -1/+1 |
| | |||||
* | Avoid pause deadlock in readexactly(). Fixes issue 99. | Guido van Rossum | 2014-01-06 | 1 | -10/+19 |
| | |||||
* | Add StreamReaderProtocol to __all__. | Guido van Rossum | 2013-11-25 | 1 | -1/+1 |
| | |||||
* | Add streams.start_server(), by Gustavo Carneiro. | Guido van Rossum | 2013-11-19 | 1 | -2/+51 |
| | |||||
* | Bulk merge | Guido van Rossum | 2013-10-18 | 1 | -58/+150 |
| | |||||
* | Merge | Guido van Rossum | 2013-10-18 | 1 | -2/+2 |
| | |||||
* | Rename tulip package to asyncio. | Guido van Rossum | 2013-10-14 | 1 | -0/+257 |