pub async fn config(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::CurrentLibraryConfig,
            >,
        ) -> Result<
                tonic::Response<tonic::codec::Streaming<super::UpdatedLibraryConfig>>,
                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/Config",
            );
            self.inner.streaming(request.into_streaming_request(), path, codec).await
        }
/// After initialization, this RPC must be kept alive for the entire life of
/// the application. The agent pushes configs down to applications via a
/// stream.
After initialization, this RPC must be kept alive for the entire life of
the application. The agent pushes configs down to applications via a
stream.
After initialization this RPC must be kept alive for the entire life of the application . The agent pushes configs down to applications via a stream .
pub async fn config(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::CurrentLibraryConfig,
            >,
        ) -> Result<
                tonic::Response<tonic::codec::Streaming<super::UpdatedLibraryConfig>>,
                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/Config",
            );
            self.inner.streaming(request.into_streaming_request(), path, codec).await
        }
pub async fn config ( & mut self , request : impl tonic :: IntoStreamingRequest < Message = super :: CurrentLibraryConfig , > , ) -> Result < tonic :: Response < tonic :: codec :: Streaming < super :: UpdatedLibraryConfig > > , 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 }
After initialization, this RPC must be kept alive for the entire life of
the application.
After initialization this RPC must be kept alive for the entire life of the application .
&mut self
request
impl tonic::IntoStreamingRequest<
                Message = super::CurrentLibraryConfig,
            >