Lines Matching refs:stream
239 let mut stream = TokenStream::new(); in generate_trait_methods() localVariable
307 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods() localVariable
315 …type #stream: tonic::codegen::tokio_stream::Stream<Item = std::result::Result<#res_message, tonic:… in generate_trait_methods()
319 -> std::result::Result<tonic::Response<Self::#stream>, tonic::Status>; in generate_trait_methods()
332 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods() localVariable
340 …type #stream: tonic::codegen::tokio_stream::Stream<Item = std::result::Result<#res_message, tonic:… in generate_trait_methods()
344 -> std::result::Result<tonic::Response<Self::#stream>, tonic::Status>; in generate_trait_methods()
349 stream.extend(method); in generate_trait_methods()
352 stream in generate_trait_methods()
377 let mut stream = TokenStream::new(); in generate_methods() localVariable
429 stream.extend(method); in generate_methods()
432 stream in generate_methods()
509 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_server_streaming() localVariable
510 quote!(type ResponseStream = T::#stream) in generate_server_streaming()
634 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_streaming() localVariable
635 quote!(type ResponseStream = T::#stream) in generate_streaming()