337 Commits

Author	SHA1	Message	Date
Aaron Piotrowski	3ce0c0dd37	Resolve with boolean, not emitted value	2016-08-23 12:50:16 -05:00
Bob Weinand	c89f10eef0	Make Observer::drain() public	2016-08-23 16:21:05 +02:00
Aaron Piotrowski	5f1354bf1a	Add drain() method to Observer	2016-08-23 08:50:04 -05:00
Aaron Piotrowski	ddefcf21f9	Implement Observable in Success and Failure	2016-08-22 16:21:47 -05:00
Aaron Piotrowski	ef143534e3	Fix issue with resolved Observer not receiving all values	2016-08-22 10:54:39 -05:00
Aaron Piotrowski	96e1178b89	Code, docblock, and comment cleanup	2016-08-17 22:25:54 -05:00
Aaron Piotrowski	a8d7d71a1a	Drop Future and Producer	2016-08-17 21:17:31 -05:00
Aaron Piotrowski	d4e83490c2	Drop unsubscribing from Observable	2016-08-17 21:11:03 -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	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	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	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	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