Aaron Piotrowski
|
8eda038155
|
Use strict types in tests; update some tests
|
2016-08-16 16:39:25 -05:00 |
|
Aaron Piotrowski
|
2317a3aa37
|
Unsubscribe from emitted observable if failed
|
2016-08-16 16:31:09 -05:00 |
|
Aaron Piotrowski
|
84c2572e0a
|
Prevent fail call after resolution
|
2016-08-16 13:30:32 -05:00 |
|
Aaron Piotrowski
|
bdc26e1e8b
|
Combine use statements
|
2016-08-16 13:07:51 -05:00 |
|
Aaron Piotrowski
|
dae4eb90da
|
Better Emitter fix; fail observable if emitted awaitable fails
|
2016-08-16 13:07:38 -05:00 |
|
Aaron Piotrowski
|
a8a5a1b3a5
|
Fix Emitter
|
2016-08-16 02:28:47 -05:00 |
|
Aaron Piotrowski
|
888229d667
|
Use strict types
|
2016-08-15 23:46:26 -05:00 |
|
Bob Weinand
|
7c9a004024
|
Fix composer build (0.2 for event-loop)
|
2016-08-15 15:47:26 +02:00 |
|
Bob Weinand
|
6a87658ad8
|
Remove bogus .coveralls.yml file
|
2016-08-15 15:41:28 +02:00 |
|
Niklas Keller
|
cef92e9770
|
Doc fixes for Coroutine
|
2016-08-14 19:17:08 +02:00 |
|
Bob Weinand
|
dcf17e3f98
|
Optimize Producer & remove wait until first subscribe
Also delay first emit in Emitter until next tick
|
2016-08-14 16:57:17 +02:00 |
|
Bob Weinand
|
08d65bcd63
|
Make Subscriber not caring about $id type
|
2016-08-14 04:47:48 +02:00 |
|
Bob Weinand
|
80265b726e
|
Do not have final methods in Struct, functions may need to be overridden
|
2016-08-14 04:41:47 +02:00 |
|
Aaron Piotrowski
|
42d9b25c3d
|
Temp var unnecessary
|
2016-08-13 10:24:55 -05:00 |
|
Aaron Piotrowski
|
7bc08b9a6a
|
Replace leftover LogicExceptions exceptions with Error
|
2016-08-12 16:58:53 -05:00 |
|
Aaron Piotrowski
|
496152282e
|
Update Amp\coroutine() tests
|
2016-08-12 16:56:13 -05:00 |
|
Aaron Piotrowski
|
2ff32c2d6b
|
Remove unnecessary default parameter values
|
2016-08-12 16:38:36 -05:00 |
|
Aaron Piotrowski
|
66c38e1480
|
Refactor Amp\coroutine()
Any function can now be passed to this function, which now returns a function returning an awaitable.
|
2016-08-12 14:50:44 -05:00 |
|
Aaron Piotrowski
|
69ec812bc0
|
Require PHP 7
|
2016-08-11 14:52:40 -05:00 |
|
Aaron Piotrowski
|
658edf33f7
|
Use Closure::fromCallable() in 7.1
|
2016-08-11 13:33:51 -05:00 |
|
Aaron Piotrowski
|
aa7b76e842
|
Add awaitable/coroutine-aware loop functions
These functions mirror the standard loop methods, but run returned Generators as coroutines and invoke rethrow() on returned awaitables.
|
2016-08-02 12:48:32 -05:00 |
|
Aaron Piotrowski
|
13908fe2e5
|
Add concat() function
|
2016-08-01 11:10:59 -05:00 |
|
Aaron Piotrowski
|
9055f159e7
|
Revert some() to v1 behavior
|
2016-07-31 00:31:04 -05:00 |
|
Aaron Piotrowski
|
bf716f4efe
|
Merge pull request #48 from mickaelandrieu/patch-1
|
2016-07-25 11:17:40 -05:00 |
|
Aaron Piotrowski
|
5da5fd5662
|
Update phpunit version
|
2016-07-25 11:11:35 -05:00 |
|
Mickaël Andrieu
|
c3674022bd
|
updated PHP CS Fixer to new organization
|
2016-07-23 00:43:16 +02:00 |
|
Aaron Piotrowski
|
0925a59db2
|
Update branch alias
|
2016-07-20 08:53:58 -05:00 |
|
Aaron Piotrowski
|
c2caca9d02
|
Fix functions using Subscriber as Awaitable
Use PHP_INT_MAX instead of 0 for infinite interval() count.
|
2016-07-20 08:53:18 -05:00 |
|
Aaron Piotrowski
|
7adc7d8452
|
Remove missed emit() default value
|
2016-07-20 08:52:19 -05:00 |
|
Aaron Piotrowski
|
8e794ba1d7
|
Fix stream()
|
2016-07-19 15:24:05 -05:00 |
|
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 |
|