pub async fn export(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::ExportTraceServiceRequest,
            >,
        ) -> Result<
                tonic::Response<
                    tonic::codec::Streaming<super::ExportTraceServiceResponse>,
                >,
                tonic::Status,
            > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/opencensus.proto.agent.trace.v1.TraceService/Export",
            );
            self.inner.streaming(request.into_streaming_request(), path, codec).await
        }
/// For performance reasons, it is recommended to keep this RPC
/// alive for the entire life of the application.
For performance reasons, it is recommended to keep this RPC
alive for the entire life of the application.
For performance reasons it is recommended to keep this RPC alive for the entire life of the application .
pub async fn export(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::ExportTraceServiceRequest,
            >,
        ) -> Result<
                tonic::Response<
                    tonic::codec::Streaming<super::ExportTraceServiceResponse>,
                >,
                tonic::Status,
            > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::new(
                        tonic::Code::Unknown,
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic::codec::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/opencensus.proto.agent.trace.v1.TraceService/Export",
            );
            self.inner.streaming(request.into_streaming_request(), path, codec).await
        }
pub async fn export ( & mut self , request : impl tonic :: IntoStreamingRequest < Message = super :: ExportTraceServiceRequest , > , ) -> Result < tonic :: Response < tonic :: codec :: Streaming < super :: ExportTraceServiceResponse > , > , tonic :: Status , > { self . inner . ready ( ) . await . map_err ( | e | { tonic :: Status :: new ( tonic :: Code :: Unknown , format ! ( " " e into ( ) ) , ) } ) ? ; let codec = tonic :: codec :: ProstCodec :: default ( ) ; let path = http :: uri :: PathAndQuery :: from_static ( " " , ) ; self . inner . streaming ( request . into_streaming_request ( ) , path , codec ) . await }
For performance reasons, it is recommended to keep this RPC
alive for the entire life of the application.
For performance reasons it is recommended to keep this RPC alive for the entire life of the application .
&mut self
request
impl tonic::IntoStreamingRequest<
                Message = super::ExportTraceServiceRequest,
            >