1 //! The futures-rs procedural macro implementations.
2
3 #![warn(rust_2018_idioms, single_use_lifetimes, unreachable_pub)]
4 #![doc(test(
5 no_crate_inject,
6 attr(
7 deny(warnings, rust_2018_idioms, single_use_lifetimes),
8 allow(dead_code, unused_assignments, unused_variables)
9 )
10 ))]
11
12 // Since https://github.com/rust-lang/cargo/pull/7700 `proc_macro` is part of the prelude for
13 // proc-macro crates, but to support older compilers we still need this explicit `extern crate`.
14 #[allow(unused_extern_crates)]
15 extern crate proc_macro;
16
17 use proc_macro::TokenStream;
18
19 mod executor;
20 mod join;
21 mod select;
22 mod stream_select;
23
24 /// The `join!` macro.
25 #[proc_macro]
join_internal(input: TokenStream) -> TokenStream26 pub fn join_internal(input: TokenStream) -> TokenStream {
27 crate::join::join(input)
28 }
29
30 /// The `try_join!` macro.
31 #[proc_macro]
try_join_internal(input: TokenStream) -> TokenStream32 pub fn try_join_internal(input: TokenStream) -> TokenStream {
33 crate::join::try_join(input)
34 }
35
36 /// The `select!` macro.
37 #[proc_macro]
select_internal(input: TokenStream) -> TokenStream38 pub fn select_internal(input: TokenStream) -> TokenStream {
39 crate::select::select(input)
40 }
41
42 /// The `select_biased!` macro.
43 #[proc_macro]
select_biased_internal(input: TokenStream) -> TokenStream44 pub fn select_biased_internal(input: TokenStream) -> TokenStream {
45 crate::select::select_biased(input)
46 }
47
48 // TODO: Change this to doc comment once rustdoc bug fixed: https://github.com/rust-lang/futures-rs/pull/2435
49 // The `test` attribute.
50 #[proc_macro_attribute]
test_internal(input: TokenStream, item: TokenStream) -> TokenStream51 pub fn test_internal(input: TokenStream, item: TokenStream) -> TokenStream {
52 crate::executor::test(input, item)
53 }
54
55 /// The `stream_select!` macro.
56 #[proc_macro]
stream_select_internal(input: TokenStream) -> TokenStream57 pub fn stream_select_internal(input: TokenStream) -> TokenStream {
58 crate::stream_select::stream_select(input.into())
59 .unwrap_or_else(syn::Error::into_compile_error)
60 .into()
61 }
62