1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74
#![doc(html_root_url = "https://docs.rs/amadeus-core/0.2.3")] #![feature(never_type)] #![feature(specialization)] #![feature(read_initializer)] #![allow(incomplete_features)] #![recursion_limit = "25600"] macro_rules! impl_par_dist { ($($body:tt)*) => { $($body)* const _: () = { use crate::impl_par_dist::*; #[allow(unused_imports)] use crate::impl_par_dist::{combiner_par_sink,folder_par_sink}; $($body)* }; } } mod impl_par_dist { pub use crate::{ combiner_dist_sink as combiner_par_sink, folder_dist_sink as folder_par_sink, par_pipe::DistributedPipe as ParallelPipe, par_sink::{DistributedSink as ParallelSink, FromDistributedStream as FromParallelStream}, par_stream::DistributedStream as ParallelStream, pool::ProcessSend as Send }; } macro_rules! impl_par_dist_rename { ($($body:tt)*) => { $($body)* rename! { [ ParallelStream DistributedStream ParallelSink DistributedSink ParallelPipe DistributedPipe FromParallelStream FromDistributedStream IntoParallelStream IntoDistributedStream ParStream DistStream Send ProcessSend ImplParallelStream ImplDistributedStream IterParStream IterDistStream into_par_stream into_dist_stream par_stream dist_stream assert_parallel_sink assert_distributed_sink assert_parallel_pipe assert_distributed_pipe assert_parallel_stream assert_distributed_stream ] $($body)* } } } macro_rules! rename { ([$($from:ident $to:ident)*] $($body:tt)*) => (rename!(@inner [$] [$($from $to)*] $($body)*);); (@inner [$d:tt] [$($from:ident $to:ident)*] $($body:tt)*) => ( macro_rules! __rename { $( (@munch [$d ($d done:tt)*] $from $d ($d body:tt)*) => (__rename!{@munch [$d ($d done)* $to] $d ($d body)*}); )* (@munch [$d ($d done:tt)*] { $d ($d head:tt)* } $d ($d body:tt)*) => (__rename!{@munch [$d ($d done)* { __rename!{$d ($d head)*} }] $d ($d body)*}); (@munch [$d ($d done:tt)*] $d head:tt $d ($d body:tt)*) => (__rename!{@munch [$d ($d done)* $d head] $d ($d body)*}); (@munch [$d ($d done:tt)*]) => ($d ($d done)*); (@__rename $d i:ident) => ($d i); ($d ($d body:tt)*) => (__rename!{@munch [] $d ($d body)*}); } __rename!($($body)*); ); } pub mod file; pub mod into_par_stream; pub mod misc_serde; pub mod par_pipe; pub mod par_sink; pub mod par_stream; pub mod pool; pub mod sink; mod source; pub mod util; pub use source::*;