Skip to content

Commit 75b266e

Browse files
carllerchecarllerche
authored
Set up CI with Azure Pipelines (#1)
1 parent 4324ea6 commit 75b266e

File tree

8 files changed

+308
-91
lines changed

8 files changed

+308
-91
lines changed

‎async-stream-impl/src/lib.rs‎

Lines changed: 22 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,9 @@ struct AsyncStreamEnumHack {
2121
impl AsyncStreamEnumHack {
2222
fn parse(input: TokenStream) -> Self {
2323
macro_rules! n {
24-
($i:ident) => { $i.next().unwrap() };
24+
($i:ident) => {
25+
$i.next().unwrap()
26+
};
2527
}
2628

2729
let mut input = input.into_iter();
@@ -46,7 +48,8 @@ impl AsyncStreamEnumHack {
4648

4749
let macro_ident = syn::Ident::new(
4850
&format!("stream_{}", count_bangs(inner.into())),
49-
Span::call_site());
51+
Span::call_site(),
52+
);
5053

5154
AsyncStreamEnumHack { stmts, macro_ident }
5255
}
@@ -91,8 +94,7 @@ impl VisitMut for Scrub {
9194
}
9295
};
9396
}
94-
syn::Expr::Closure(_) |
95-
syn::Expr::Async(_) => {
97+
syn::Expr::Closure(_) | syn::Expr::Async(_) => {
9698
let prev = self.is_xforming;
9799
self.is_xforming = false;
98100
syn::visit_mut::visit_expr_mut(self, i);
@@ -112,8 +114,10 @@ impl VisitMut for Scrub {
112114

113115
#[proc_macro_derive(AsyncStreamHack)]
114116
pub fn async_stream_impl(input: TokenStream) -> TokenStream {
115-
let AsyncStreamEnumHack { macro_ident, mut stmts } =
116-
AsyncStreamEnumHack::parse(input);
117+
let AsyncStreamEnumHack {
118+
macro_ident,
119+
mut stmts,
120+
} = AsyncStreamEnumHack::parse(input);
117121

118122
let mut scrub = Scrub {
119123
is_xforming: true,
@@ -135,20 +139,24 @@ pub fn async_stream_impl(input: TokenStream) -> TokenStream {
135139

136140
#(#stmts)*
137141
}};
138-
}).into()
142+
})
143+
.into()
139144
} else {
140145
quote!(macro_rules! #macro_ident {
141146
() => {{
142147
#(#stmts)*
143148
}};
144-
}).into()
149+
})
150+
.into()
145151
}
146152
}
147153

148154
#[proc_macro_derive(AsyncTryStreamHack)]
149155
pub fn async_try_stream_impl(input: TokenStream) -> TokenStream {
150-
let AsyncStreamEnumHack { macro_ident, mut stmts } =
151-
AsyncStreamEnumHack::parse(input);
156+
let AsyncStreamEnumHack {
157+
macro_ident,
158+
mut stmts,
159+
} = AsyncStreamEnumHack::parse(input);
152160

153161
let mut scrub = Scrub {
154162
is_xforming: true,
@@ -170,13 +178,15 @@ pub fn async_try_stream_impl(input: TokenStream) -> TokenStream {
170178

171179
#(#stmts)*
172180
}};
173-
}).into()
181+
})
182+
.into()
174183
} else {
175184
quote!(macro_rules! #macro_ident {
176185
() => {{
177186
#(#stmts)*
178187
}};
179-
}).into()
188+
})
189+
.into()
180190
}
181191
}
182192

‎async-stream/src/async_stream.rs‎

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,17 @@ pub struct AsyncStream<T, U> {
1313

1414
impl<T, U> AsyncStream<T, U> {
1515
pub fn new(rx: Receiver<T>, generator: U) -> AsyncStream<T, U> {
16-
AsyncStream { rx, done: false, generator }
16+
AsyncStream {
17+
rx,
18+
done: false,
19+
generator,
20+
}
1721
}
1822
}
1923

2024
impl<T, U> Stream for AsyncStream<T, U>
21-
where U: Future<Output = ()>
25+
where
26+
U: Future<Output = ()>,
2227
{
2328
type Item = T;
2429

‎async-stream/src/lib.rs‎

Lines changed: 196 additions & 68 deletions
Original file line numberDiff line numberDiff line change
@@ -174,9 +174,7 @@ pub mod yielder;
174174

175175
// Used by the macro, but not intended to be accessed publically.
176176
#[doc(hidden)]
177-
pub use crate::{
178-
async_stream::AsyncStream,
179-
};
177+
pub use crate::async_stream::AsyncStream;
180178

181179
#[doc(hidden)]
182180
pub use async_stream_impl::{AsyncStreamHack, AsyncTryStreamHack};
@@ -307,69 +305,199 @@ macro_rules! dispatch {
307305
#[doc(hidden)]
308306
#[macro_export]
309307
macro_rules! count {
310-
() => { stream_0!() };
311-
(!) => { stream_1!() };
312-
(!!) => { stream_2!() };
313-
(!!!) => { stream_3!() };
314-
(!!!!) => { stream_4!() };
315-
(!!!!!) => { stream_5!() };
316-
(!!!!!!) => { stream_6!() };
317-
(!!!!!!!) => { stream_7!() };
318-
(!!!!!!!!) => { stream_8!() };
319-
(!!!!!!!!!) => { stream_9!() };
320-
(!!!!!!!!!!) => { stream_10!() };
321-
(!!!!!!!!!!!) => { stream_11!() };
322-
(!!!!!!!!!!!!) => { stream_12!() };
323-
(!!!!!!!!!!!!!) => { stream_13!() };
324-
(!!!!!!!!!!!!!!) => { stream_14!() };
325-
(!!!!!!!!!!!!!!!) => { stream_15!() };
326-
(!!!!!!!!!!!!!!!!) => { stream_16!() };
327-
(!!!!!!!!!!!!!!!!!) => { stream_17!() };
328-
(!!!!!!!!!!!!!!!!!!) => { stream_18!() };
329-
(!!!!!!!!!!!!!!!!!!!) => { stream_19!() };
330-
(!!!!!!!!!!!!!!!!!!!!) => { stream_20!() };
331-
(!!!!!!!!!!!!!!!!!!!!!) => { stream_21!() };
332-
(!!!!!!!!!!!!!!!!!!!!!!) => { stream_22!() };
333-
(!!!!!!!!!!!!!!!!!!!!!!!) => { stream_23!() };
334-
(!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_24!() };
335-
(!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_25!() };
336-
(!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_26!() };
337-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_27!() };
338-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_28!() };
339-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_29!() };
340-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_30!() };
341-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_31!() };
342-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_32!() };
343-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_33!() };
344-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_34!() };
345-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_35!() };
346-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_36!() };
347-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_37!() };
348-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_38!() };
349-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_39!() };
350-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_40!() };
351-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_41!() };
352-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_42!() };
353-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_43!() };
354-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_44!() };
355-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_45!() };
356-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_46!() };
357-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_47!() };
358-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_48!() };
359-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_49!() };
360-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_50!() };
361-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_51!() };
362-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_52!() };
363-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_53!() };
364-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_54!() };
365-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_55!() };
366-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_56!() };
367-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_57!() };
368-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_58!() };
369-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_59!() };
370-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_60!() };
371-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_61!() };
372-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_62!() };
373-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_63!() };
374-
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => { stream_64!() };
308+
() => {
309+
stream_0!()
310+
};
311+
(!) => {
312+
stream_1!()
313+
};
314+
(!!) => {
315+
stream_2!()
316+
};
317+
(!!!) => {
318+
stream_3!()
319+
};
320+
(!!!!) => {
321+
stream_4!()
322+
};
323+
(!!!!!) => {
324+
stream_5!()
325+
};
326+
(!!!!!!) => {
327+
stream_6!()
328+
};
329+
(!!!!!!!) => {
330+
stream_7!()
331+
};
332+
(!!!!!!!!) => {
333+
stream_8!()
334+
};
335+
(!!!!!!!!!) => {
336+
stream_9!()
337+
};
338+
(!!!!!!!!!!) => {
339+
stream_10!()
340+
};
341+
(!!!!!!!!!!!) => {
342+
stream_11!()
343+
};
344+
(!!!!!!!!!!!!) => {
345+
stream_12!()
346+
};
347+
(!!!!!!!!!!!!!) => {
348+
stream_13!()
349+
};
350+
(!!!!!!!!!!!!!!) => {
351+
stream_14!()
352+
};
353+
(!!!!!!!!!!!!!!!) => {
354+
stream_15!()
355+
};
356+
(!!!!!!!!!!!!!!!!) => {
357+
stream_16!()
358+
};
359+
(!!!!!!!!!!!!!!!!!) => {
360+
stream_17!()
361+
};
362+
(!!!!!!!!!!!!!!!!!!) => {
363+
stream_18!()
364+
};
365+
(!!!!!!!!!!!!!!!!!!!) => {
366+
stream_19!()
367+
};
368+
(!!!!!!!!!!!!!!!!!!!!) => {
369+
stream_20!()
370+
};
371+
(!!!!!!!!!!!!!!!!!!!!!) => {
372+
stream_21!()
373+
};
374+
(!!!!!!!!!!!!!!!!!!!!!!) => {
375+
stream_22!()
376+
};
377+
(!!!!!!!!!!!!!!!!!!!!!!!) => {
378+
stream_23!()
379+
};
380+
(!!!!!!!!!!!!!!!!!!!!!!!!) => {
381+
stream_24!()
382+
};
383+
(!!!!!!!!!!!!!!!!!!!!!!!!!) => {
384+
stream_25!()
385+
};
386+
(!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
387+
stream_26!()
388+
};
389+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
390+
stream_27!()
391+
};
392+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
393+
stream_28!()
394+
};
395+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
396+
stream_29!()
397+
};
398+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
399+
stream_30!()
400+
};
401+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
402+
stream_31!()
403+
};
404+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
405+
stream_32!()
406+
};
407+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
408+
stream_33!()
409+
};
410+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
411+
stream_34!()
412+
};
413+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
414+
stream_35!()
415+
};
416+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
417+
stream_36!()
418+
};
419+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
420+
stream_37!()
421+
};
422+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
423+
stream_38!()
424+
};
425+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
426+
stream_39!()
427+
};
428+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
429+
stream_40!()
430+
};
431+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
432+
stream_41!()
433+
};
434+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
435+
stream_42!()
436+
};
437+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
438+
stream_43!()
439+
};
440+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
441+
stream_44!()
442+
};
443+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
444+
stream_45!()
445+
};
446+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
447+
stream_46!()
448+
};
449+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
450+
stream_47!()
451+
};
452+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
453+
stream_48!()
454+
};
455+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
456+
stream_49!()
457+
};
458+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
459+
stream_50!()
460+
};
461+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
462+
stream_51!()
463+
};
464+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
465+
stream_52!()
466+
};
467+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
468+
stream_53!()
469+
};
470+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
471+
stream_54!()
472+
};
473+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
474+
stream_55!()
475+
};
476+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
477+
stream_56!()
478+
};
479+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
480+
stream_57!()
481+
};
482+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
483+
stream_58!()
484+
};
485+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
486+
stream_59!()
487+
};
488+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
489+
stream_60!()
490+
};
491+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
492+
stream_61!()
493+
};
494+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
495+
stream_62!()
496+
};
497+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
498+
stream_63!()
499+
};
500+
(!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!) => {
501+
stream_64!()
502+
};
375503
}

0 commit comments

Comments
 (0)