ribir_macros 0.4.0-alpha.65

use proc_macro2::TokenStream;
use quote::quote_spanned;
use syn::spanned::Spanned;

use crate::{error::result_to_token_stream, symbol_process::*, watch_macro::*};

pub fn gen_code(input: TokenStream, refs_ctx: Option<&mut DollarRefsCtx>) -> TokenStream {
  let span = input.span();
  let res = process_pipe_body(input, refs_ctx).map(|WatchBody { upstream, map_handler }| {
    quote_spanned! {span => Pipe::new(#upstream.box_it(), #map_handler) }
  });
  result_to_token_stream(res)
}