Aaron Piotrowski
|
24142496d8
|
Rethrow subscriber callback exceptions from loop
|
2016-07-19 15:13:56 -05:00 |
|
Bob Weinand
|
1642bf9195
|
s/settle/any/ which now returns [$errors, $succeeds]
|
2016-07-19 21:39:09 +02:00 |
|
Aaron Piotrowski
|
bec838b693
|
Remove leftover exception class
No longer needed as Subscriber is not an awaitable.
|
2016-07-19 13:30:28 -05:00 |
|
Aaron Piotrowski
|
70123b9a44
|
Update Producer::resolve(); fix emitting observable
|
2016-07-19 13:19:44 -05:00 |
|
Aaron Piotrowski
|
9839343bbb
|
Remove default value from emit
|
2016-07-19 13:10:15 -05:00 |
|
Aaron Piotrowski
|
13a6fc59c4
|
Producer::init() -> private
|
2016-07-19 12:42:58 -05:00 |
|
Aaron Piotrowski
|
32b4721c5e
|
Subscriber no longer implements Awaitable
|
2016-07-19 12:40:16 -05:00 |
|
Aaron Piotrowski
|
90d744537e
|
protected -> private in internal traits
|
2016-07-19 12:32:43 -05:00 |
|
Aaron Piotrowski
|
3e170639c3
|
Remove final from Observer and Subscriber
|
2016-07-19 11:58:20 -05:00 |
|
Aaron Piotrowski
|
5a06b1cdc1
|
Update tests and remove unused tests
|
2016-07-19 00:05:40 -05:00 |
|
Aaron Piotrowski
|
dad93a6da0
|
Merge branch 'observable' into v2
|
2016-07-18 23:29:19 -05:00 |
|
Aaron Piotrowski
|
b9d554dd7b
|
Add more functions
|
2016-07-18 23:23:25 -05:00 |
|
Aaron Piotrowski
|
c561197d1d
|
Remove unused v1 files
|
2016-07-18 23:22:07 -05:00 |
|
Aaron Piotrowski
|
ade997688a
|
Merge branch 'awaitable' into v2
|
2016-07-18 23:20:05 -05:00 |
|
Aaron Piotrowski
|
3f654cbd5b
|
Initial tests plus some fixes
|
2016-07-12 11:20:06 -05:00 |
|
Aaron Piotrowski
|
4ed8e65468
|
Cleaner resolution
|
2016-06-16 23:27:14 -05:00 |
|
Aaron Piotrowski
|
92767755ee
|
Avoid loosing exception thrown from generator after invalid yield
|
2016-06-16 22:44:32 -05:00 |
|
Aaron Piotrowski
|
f553e4f08b
|
Improve coroutine continuation
Duplicated some code for faster coroutine continuation.
|
2016-06-14 23:26:59 -05:00 |
|
Aaron Piotrowski
|
ae182165e5
|
Remove circular reference check
|
2016-06-14 21:53:50 -05:00 |
|
Aaron Piotrowski
|
60d560d70e
|
Add $className param to capture(); other cleanup
|
2016-06-14 21:40:04 -05:00 |
|
Aaron Piotrowski
|
808ce32e3c
|
Fix leftover mentions of Disposable
|
2016-06-02 17:11:25 -05:00 |
|
Aaron Piotrowski
|
548a9fd556
|
Fix bug when emitting failed awaitable and waiting for a subscriber
|
2016-06-02 17:05:22 -05:00 |
|
Aaron Piotrowski
|
7fb57141d2
|
Cleanup yielded value handling
|
2016-06-02 10:46:22 -05:00 |
|
Aaron Piotrowski
|
5715bec9e1
|
Refactor functions with Emitter
|
2016-06-02 10:43:46 -05:00 |
|
Aaron Piotrowski
|
cef5c90168
|
Drop disposable interface; rename dispose() to unsubscribe()
|
2016-06-02 10:42:22 -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
|
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
|
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 |
|
Aaron Piotrowski
|
dd70850682
|
Remove driver argument
|
2016-05-26 00:09:50 -05:00 |
|
Aaron Piotrowski
|
b436a56869
|
Remove unused property
|
2016-05-24 12:09:52 -05:00 |
|
Aaron Piotrowski
|
a9362780ed
|
Initial commit
|
2016-05-24 11:47:14 -05:00 |
|
Aaron Piotrowski
|
ccec7acc94
|
Remove Exception namespace
|
2016-05-24 10:39:19 -05:00 |
|
Aaron Piotrowski
|
6d263ffb84
|
Drop Awaitable from namespace
|
2016-05-23 22:48:28 -05:00 |
|
Aaron Piotrowski
|
8b42994ec9
|
Fix exception creation
|
2016-05-23 21:36:29 -05:00 |
|
Aaron Piotrowski
|
13e807d564
|
Throw on repeated resolution
|
2016-05-23 21:32:41 -05:00 |
|
Aaron Piotrowski
|
6fc6ad1ab5
|
Throw instead of returning Failure object
|
2016-05-23 10:19:48 -05:00 |
|
Aaron Piotrowski
|
28577cf6e6
|
Add Pause; update for timer watcher changes in loop
|
2016-05-23 00:44:35 -05:00 |
|
Aaron Piotrowski
|
378990fe86
|
Use $exception instead of passing as callback data
Less code this way
|
2016-05-22 13:43:37 -05:00 |
|