Lines Matching refs:method

241     for method in service.methods() {  in generate_trait_methods()
242 let name = quote::format_ident!("{}", method.name()); in generate_trait_methods()
245 method.request_response_name(proto_path, compile_well_known_types); in generate_trait_methods()
248 if disable_comments.contains(&format_method_name(service, method, emit_package)) { in generate_trait_methods()
251 generate_doc_comments(method.comment()) in generate_trait_methods()
260 let method = match ( in generate_trait_methods() localVariable
261 method.client_streaming(), in generate_trait_methods()
262 method.server_streaming(), in generate_trait_methods()
307 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods()
310 method.identifier() in generate_trait_methods()
332 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_trait_methods()
335 method.identifier() in generate_trait_methods()
349 stream.extend(method); in generate_trait_methods()
379 for method in service.methods() { in generate_methods()
380 let path = format_method_path(service, method, emit_package); in generate_methods()
382 let ident = quote::format_ident!("{}", method.name()); in generate_methods()
385 let method_stream = match (method.client_streaming(), method.server_streaming()) { in generate_methods()
387 method, in generate_methods()
396 method, in generate_methods()
405 method, in generate_methods()
414 method, in generate_methods()
424 let method = quote! { in generate_methods() localVariable
429 stream.extend(method); in generate_methods()
436 method: &T, in generate_unary()
443 let codec_name = syn::parse_str::<syn::Path>(method.codec_path()).unwrap(); in generate_unary()
445 let service_ident = quote::format_ident!("{}Svc", method.identifier()); in generate_unary()
447 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_unary()
478 let method = #service_ident(inner); in generate_unary() localVariable
485 let res = grpc.unary(method, req).await; in generate_unary()
494 method: &T, in generate_server_streaming()
502 let codec_name = syn::parse_str::<syn::Path>(method.codec_path()).unwrap(); in generate_server_streaming()
504 let service_ident = quote::format_ident!("{}Svc", method.identifier()); in generate_server_streaming()
506 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_server_streaming()
509 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_server_streaming()
545 let method = #service_ident(inner); in generate_server_streaming() localVariable
552 let res = grpc.server_streaming(method, req).await; in generate_server_streaming()
561 method: &T, in generate_client_streaming()
568 let service_ident = quote::format_ident!("{}Svc", method.identifier()); in generate_client_streaming()
570 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_client_streaming()
571 let codec_name = syn::parse_str::<syn::Path>(method.codec_path()).unwrap(); in generate_client_streaming()
603 let method = #service_ident(inner); in generate_client_streaming() localVariable
610 let res = grpc.client_streaming(method, req).await; in generate_client_streaming()
619 method: &T, in generate_streaming()
627 let codec_name = syn::parse_str::<syn::Path>(method.codec_path()).unwrap(); in generate_streaming()
629 let service_ident = quote::format_ident!("{}Svc", method.identifier()); in generate_streaming()
631 let (request, response) = method.request_response_name(proto_path, compile_well_known_types); in generate_streaming()
634 let stream = quote::format_ident!("{}Stream", method.identifier()); in generate_streaming()
671 let method = #service_ident(inner); in generate_streaming() localVariable
678 let res = grpc.streaming(method, req).await; in generate_streaming()