368 commits

Author	SHA1	Message	Date
Yoshua Wuyts	d51a135015	Merge pull request #309 from async-rs/stream-delay ... Stream::delay	2019-11-30 11:25:41 +09:00
k-nasa	fb1fb6c903	test: Test the delay time	2019-11-28 22:53:24 +09:00
k-nasa	da965e9ba4	fix indent	2019-11-28 15:54:13 +09:00
k-nasa	9f7c1833dc	fix module	2019-11-28 10:37:04 +09:00
Yoshua Wuyts	68005661d9	fix Stream::throttle hot loop (#584) ... Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>	2019-11-27 15:47:27 +01:00
k-nasa	32765ece41	test: Add stream::delay test code	2019-11-27 14:26:25 +09:00
k-nasa	635c592950	feat: Add stream::delay	2019-11-27 14:26:04 +09:00
k-nasa	3b055f364e	Merge branch 'master' into stream-delay	2019-11-27 13:50:05 +09:00
Yoshua Wuyts	850b8ae9d0	Merge pull request #543 from k-nasa/stream_unzip ... Add stream unzip	2019-11-25 20:25:44 +01:00
laizy	ec5415358f	simplify AllFuture and AnyFuture (#572)	2019-11-21 18:03:23 +01:00
nasa	d146d95a39	Update src/stream/stream/mod.rs ... Co-Authored-By: Taiki Endo <te316e89@gmail.com>	2019-11-20 21:38:42 +09:00
Stjepan Glavina	5fba3a0928	Fix rng use in Stream::merge	2019-11-20 13:24:18 +01:00
Yoshua Wuyts	8ea920c9f0	Merge pull request #546 from k-nasa/fix_clippy ... Fix clippy warn	2019-11-20 12:26:28 +01:00
Yoshua Wuyts	d1189f9974	Merge pull request #548 from yjhmelody/fix-stream-code-style ... fix stream code style	2019-11-20 12:25:11 +01:00
nasa	3bc4d293dd	Merge pull request #503 from Razican/random_merge ... Randomize Stream::merge to improve the throughput.	2019-11-20 08:42:50 +09:00
razican	72ca2c1a24	Improved the code with some minor changes	2019-11-19 21:14:56 +01:00
k-nasa	b5e66c4f93	refactor: Refactoring option type handling	2019-11-20 00:38:51 +09:00
k-nasa	080875edc9	update min_by_key doc	2019-11-20 00:25:48 +09:00
k-nasa	ca71ad073b	fix stream min_by_key mistake	2019-11-20 00:25:35 +09:00
k-nasa	667bbc1019	doc: update doc test	2019-11-20 00:18:11 +09:00
k-nasa	64b2e10b93	fix max_by_key mistake	2019-11-20 00:17:29 +09:00
k-nasa	314a75da28	fix typo	2019-11-20 00:00:54 +09:00
Stjepan Glavina	65afd41a33	Once doesn't need Unpin bound (#554)	2019-11-19 05:04:18 +01:00
Razican	f6829859fe	Fixed deduplication of code	2019-11-18 16:39:21 +01:00
yjhmelody	223fcc30ee	fix code style for stream	2019-11-17 00:35:56 +08:00
k-nasa	76975a4441	Merge branch 'master' into fix_clippy	2019-11-16 02:41:39 +09:00
Yoshua Wuyts	355e2eded8	Merge pull request #547 from async-rs/unpin-successors-test ... remove pin_mut from successors test	2019-11-15 18:24:58 +01:00
Yoshua Wuyts	ee23ba6e94	Merge pull request #545 from yjhmelody/stream-partition-patch ... use `as_mut` for stream-partition	2019-11-15 18:08:51 +01:00
Yoshua Wuyts	d68dc659b2	remove pin_mut from successors test ... Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>	2019-11-15 18:08:00 +01:00
Yoshua Wuyts	b5c3fb8bb5	Merge pull request #363 from felipesere/async-successors ... Async successors	2019-11-15 18:04:10 +01:00
k-nasa	7d616c695d	refactor: change to as_mut	2019-11-16 01:58:45 +09:00
yjhmelody	a69b3a8a9e	use as_mut for stream-partition	2019-11-16 00:54:50 +08:00
k-nasa	a05b6a3810	fix: mutable ref	2019-11-16 01:36:53 +09:00
k-nasa	6cbf48f12d	fix clippy warn	2019-11-16 01:29:16 +09:00
k-nasa	91ee4c7b9f	doc: Add stream unzip doc	2019-11-16 01:16:48 +09:00
k-nasa	603b3c5085	add: Add stream unzip	2019-11-16 01:16:35 +09:00
Yoshua Wuyts	693a7257b8	Merge pull request #538 from k-nasa/stream_by_ref ... Add stream by_ref	2019-11-15 17:14:17 +01:00
k-nasa	df92c63337	fix: Add unstable features	2019-11-16 00:29:54 +09:00
k-nasa	31cf932d80	wip: Add stream unzip	2019-11-16 00:24:59 +09:00
Yoshua Wuyts	3c6d41ccb4	Merge pull request #541 from yjhmelody/stream-partition ... add stream-partition	2019-11-15 14:27:42 +01:00
yjhmelody	76ec9c4563	update doc url	2019-11-15 14:33:34 +08:00
yjhmelody	d76b32e6d4	make it unstable and fix trait bound	2019-11-15 14:23:34 +08:00
yjhmelody	11268a80fb	add stream-partition	2019-11-15 12:28:03 +08:00
k-nasa	de67bf0fd4	feat: Add stream by_ref	2019-11-15 11:17:39 +09:00
Yoshua Wuyts	30ff7b09b6	mark Stream::count as unstable ... Signed-off-by: Yoshua Wuyts <yoshuawuyts@gmail.com>	2019-11-14 22:45:46 +01:00
Yoshua Wuyts	c58747b5fc	Merge pull request #368 from starsheriff/stream_count ... add stream::count	2019-11-14 22:40:45 +01:00
Felipe Sere	64216b8e6b	Take a normal closure, not an async one	2019-11-14 21:49:24 +01:00
Felipe Sere	786a52a09d	Slight miss-merge	2019-11-14 21:37:51 +01:00
Felipe Sere	f14b37ff17	Remoe the T: Copy bound on the item	2019-11-14 21:35:38 +01:00
Felipe Sere	7677e9a3df	Make the closure take a borrow to the value	2019-11-14 21:35:38 +01:00