Searched refs:jh (Results 1 – 14 of 14) sorted by relevance
27 let jh = tokio::spawn(async move { in http2_keepalive_does_not_cause_panics() localVariable45 jh.await.unwrap(); in http2_keepalive_does_not_cause_panics()57 let jh = tokio::spawn(async move { in http2_keepalive_does_not_cause_panics_on_client_side() localVariable81 jh.await.unwrap(); in http2_keepalive_does_not_cause_panics_on_client_side()
47 let jh = tokio::spawn(async move { in connect_returns_err_via_call_after_connected() localVariable69 jh.await.unwrap(); in connect_returns_err_via_call_after_connected()91 let jh = tokio::spawn(async move { in connect_lazy_reconnects_after_first_failure() localVariable114 jh.await.unwrap(); in connect_lazy_reconnects_after_first_failure()
35 let jh = tokio::spawn(async move { in getting_connect_info() localVariable57 jh.await.unwrap(); in getting_connect_info()107 let jh = tokio::spawn(async move { in getting_connect_info() localVariable132 jh.await.unwrap(); in getting_connect_info()
46 let jh = tokio::spawn(async move { in setting_extension_from_interceptor() localVariable68 jh.await.unwrap(); in setting_extension_from_interceptor()95 let jh = tokio::spawn(async move { in setting_extension_from_tower() localVariable117 jh.await.unwrap(); in setting_extension_from_tower()
31 let jh = tokio::spawn(async move { in status_from_server_stream_with_source() localVariable41 jh.await.unwrap(); in status_from_server_stream_with_source()
31 let jh = tokio::spawn(async move { in writes_user_agent_header() localVariable58 jh.await.unwrap(); in writes_user_agent_header()
31 let jh = tokio::spawn(async move { in interceptor_retrieves_grpc_method() localVariable58 jh.await.unwrap(); in interceptor_retrieves_grpc_method()
36 let jh = tokio::spawn(async move { in test_http_max_header_list_size_and_long_errors() localVariable69 jh.await.unwrap(); in test_http_max_header_list_size_and_long_errors()
34 let jh = tokio::spawn(async move { in connect_supports_standard_tower_layers() localVariable62 jh.await.unwrap(); in connect_supports_standard_tower_layers()
41 let jh = tokio::spawn(async move { in status_with_details() localVariable65 jh.await.unwrap(); in status_with_details()99 let jh = tokio::spawn(async move { in status_with_metadata() localVariable135 jh.await.unwrap(); in status_with_metadata()
38 let jh = tokio::spawn(async move { in writes_origin_header() localVariable65 jh.await.unwrap(); in writes_origin_header()
64 let jh = tokio::spawn(async move { in multiple_service_using_routes_builder() localVariable110 jh.await.unwrap(); in multiple_service_using_routes_builder()
69 let jh = tokio::spawn(async move { in make_v1_request() localVariable112 jh.await.expect("server shutdown"); in make_v1_request()126 let jh = tokio::spawn(async move { in make_v1alpha_request() localVariable169 jh.await.expect("server shutdown"); in make_v1alpha_request()
102 let jh = tokio::spawn(async move { in make_test_reflection_request() localVariable148 jh.await.expect("server shutdown"); in make_test_reflection_request()