1
0
mirror of https://github.com/danog/amp.git synced 2024-12-14 02:17:26 +01:00
Commit Graph

1141 Commits

Author SHA1 Message Date
Aaron Piotrowski
cef5c90168 Drop disposable interface; rename dispose() to unsubscribe() 2016-06-02 10:42:22 -05:00
Aaron Piotrowski
acbe2c8237 Add Registry; support streams with multiple watchers 2016-06-02 09:45:04 -05:00
Aaron Piotrowski
055d7d4c52 Update docblocks 2016-06-01 12:18:11 -05:00
Aaron Piotrowski
cd6939db5a Build awaitable in when() 2016-06-01 12:10:46 -05:00
Aaron Piotrowski
b705c144c6 Minor tweaks 2016-06-01 12:06:43 -05:00
Aaron Piotrowski
906d6db47a Update docblocks 2016-06-01 11:37:12 -05:00
Aaron Piotrowski
c4e9a19095 Rename Emitter to Producer; add new Emitter class
Emitter uses a coroutine to emit values. Updated examples.
2016-06-01 11:19:19 -05:00
Aaron Piotrowski
cc431a0374 Prevent emit without subscribers 2016-05-31 23:02:59 -05:00
Aaron Piotrowski
eb49e6e8ff Resolve emit with observable result instead of emitting
Emitting another observable will emit values from the emitted observable, then resolve the awaitable returned from emit with the observable result
2016-05-31 16:23:01 -05:00
Aaron Piotrowski
a52e1e4c33 Rename Observer methods 2016-05-31 14:45:14 -05:00
Aaron Piotrowski
ae441eb179 Fix DummyDriver
Conflict due to merge of #68
2016-05-31 10:08:10 -05:00
Aaron Piotrowski
5a82cd9b6b Merge pull request #67 from async-interop/defer-callback
Put Loop::execute() $callback into Driver::defer()
2016-05-31 10:00:11 -05:00
Aaron Piotrowski
3b338b5800 Merge pull request #65 from async-interop/lazy-fast-loop
Lazy factory instantiation and save method call
2016-05-31 09:57:18 -05:00
Bob Weinand
a503b8598d Lazy factory instantiation and save method call 2016-05-31 14:50:33 +02:00
Bob Weinand
1c30c349c4 Merge pull request #68 from async-interop/driver-registry
Driver registry
2016-05-31 14:46:57 +02:00
Aaron Piotrowski
1b079bb336 Fix Observer 2016-05-30 00:34:44 -05:00
Aaron Piotrowski
579ab2fc96 Update example 2016-05-29 12:07:21 -05:00
Aaron Piotrowski
57e25f9354 Simpler implementation 2016-05-29 11:46:58 -05:00
Aaron Piotrowski
da3bbdf90c Null default for Success 2016-05-29 10:40:00 -05:00
Aaron Piotrowski
4a2baa670e Subscriber model 2016-05-27 15:44:01 -05:00
Aaron Piotrowski
4aa8c5d550 Add loop tests 2016-05-27 15:07:05 -05:00
Aaron Piotrowski
ff1e57a7cd Fix autoloader namespace 2016-05-27 14:55:19 -05:00
Aaron Piotrowski
237a9c45ad Update registry test 2016-05-27 11:38:19 -05:00
Aaron Piotrowski
4908813e08 Refactor Registry for Drivers 2016-05-27 10:45:45 -05:00
Aaron Piotrowski
ca827319ec Standard updates and more
Update for changes in async-interop/event-loop.
Do not invalidate delay and defer on disable.
Better watcher ID generation.
Throw if enabling invalid watcher.
2016-05-27 10:16:36 -05:00
Bob Weinand
de3c259557 Turns out it is better to not fail for invalid watcher ids 2016-05-27 15:20:39 +02:00
Bob Weinand
104b761e59 Revert "Merge pull request #63 from async-interop/throw-on-invalid-watcher"
This reverts commit 5bd7794dfa, reversing
changes made to 64494951ff.

Revert too quick merge (sorry) as per #58
2016-05-27 14:57:11 +02:00
Bob Weinand
e74f09a741 Fix incomplete/skipped marking 2016-05-27 04:17:30 +02:00
Bob Weinand
e2f11010c0 Fix loop->stop() test and incomplete/skipped marking 2016-05-27 04:08:34 +02:00
Bob Weinand
572c99bb85 Initial commit 2016-05-27 03:25:55 +02:00
Bob Weinand
5bd7794dfa Merge pull request #63 from async-interop/throw-on-invalid-watcher
Throw on invalid watcher identifier
2016-05-27 03:24:00 +02:00
Aaron Piotrowski
99eecc1a3f Refactor 2016-05-26 18:20:05 -05:00
Aaron Piotrowski
3edab2dfd3 Put Loop::get() back
Why do I keep thinking null uses the current loop... bah
2016-05-26 18:15:33 -05:00
Bob Weinand
b197b2c07d Put Loop::execute() $callback into Driver::defer()
This also ensures that potential throwing in the callback will be handled inside a potential error handler instead of immediately falling through.
2016-05-26 23:45:27 +02:00
Aaron Piotrowski
b8f0d521ba Add note that disable must not invalidate 2016-05-26 12:36:56 -05:00
Aaron Piotrowski
b7ed0afd02 Add "or cancelled" to throw condition 2016-05-26 11:10:44 -05:00
Aaron Piotrowski
61c13e209f Extend LogicException instead 2016-05-26 11:07:42 -05:00
Aaron Piotrowski
7c34146ac8 Add InvalidWatcherException 2016-05-26 10:43:03 -05:00
Aaron Piotrowski
64494951ff use -> namespace 2016-05-26 10:40:50 -05:00
Bob Weinand
6c8d31bc8a Merge pull request #62 from async-interop/cleanup-namespace
Cleanup namespace
2016-05-26 17:27:23 +02:00
Aaron Piotrowski
7a2c5cdc88 Cleanup namespace 2016-05-26 10:05:17 -05:00
Aaron Piotrowski
12102e773a Merge pull request #59 from async-interop/fix-running
Fix running flag, factory reset, etc.
2016-05-26 09:44:41 -05:00
Aaron Piotrowski
dd70850682 Remove driver argument 2016-05-26 00:09:50 -05:00
Aaron Piotrowski
ae225835f2 Drop exception namespace 2016-05-25 23:24:06 -05:00
Aaron Piotrowski
a68bde6449 Eliminate watcher constructors 2016-05-25 23:21:49 -05:00
Niklas Keller
52a13b69dd Fix se stupid composer 2016-05-25 13:55:36 +02:00
Niklas Keller
47edee535d Forbid new factories while running, add scope test 2016-05-25 13:55:36 +02:00
Niklas Keller
476bb2305b Fix loop running flag to support nesting properly 2016-05-25 13:55:36 +02:00
Bob Weinand
5859044b82 Merge pull request #53 from async-interop/spec
Add further specification for loop drivers
2016-05-25 01:55:34 +02:00
Aaron Piotrowski
b436a56869 Remove unused property 2016-05-24 12:09:52 -05:00