mac openssl ci issues Signed-off-by: Taddes <[email protected]>

Signed-off-by: Taddes <[email protected]>

Author: taddes

src/call/client.rs

@@ -437,7 +437,7 @@ impl<Req> StreamingCallSink<Req> {
     /// The rules are listed as below:
     /// - All messages except the last one will be sent with `buffer_hint` set to true.
     /// - The last message will also be sent with `buffer_hint` set to true unless any message is
-    ///    offered with buffer hint set to false.
+    ///  offered with buffer hint set to false.
     ///
     /// No matter `enhance_batch` is true or false, it's recommended to follow the contract of
     /// Sink and call `poll_flush` to ensure messages are handled by gRPC C Core.

src/call/server.rs

@@ -482,7 +482,7 @@ macro_rules! impl_stream_sink {
             /// The rules are listed as below:
             /// - All messages except the last one will be sent with `buffer_hint` set to true.
             /// - The last message will also be sent with `buffer_hint` set to true unless any message is
-            ///    offered with buffer hint set to false.
+            ///  offered with buffer hint set to false.
             ///
             /// No matter `enhance_batch` is true or false, it's recommended to follow the contract of
             /// Sink and call `poll_flush` to ensure messages are handled by gRPC C Core.
@@ -617,24 +617,24 @@ macro_rules! impl_stream_sink {
 }
 
 impl_stream_sink!(
-    /// A sink for server streaming call.
-    ///
-    /// To close the sink properly, you should call [`close`] or [`fail`] before dropping.
-    ///
-    /// [`close`]: #method.close
-    /// [`fail`]: #method.fail
+/// A sink for server streaming call.
+///
+/// To close the sink properly, you should call [`close`] or [`fail`] before dropping.
+///
+/// [`close`]: #method.close
+/// [`fail`]: #method.fail
     #[must_use = "if unused the sink may immediately cancel the RPC"]
     ServerStreamingSink,
     ServerStreamingSinkFailure,
     ShareCall
 );
 impl_stream_sink!(
-    /// A sink for duplex streaming call.
-    ///
-    /// To close the sink properly, you should call [`close`] or [`fail`] before dropping.
-    ///
-    /// [`close`]: #method.close
-    /// [`fail`]: #method.fail
+/// A sink for duplex streaming call.
+///
+/// To close the sink properly, you should call [`close`] or [`fail`] before dropping.
+///
+/// [`close`]: #method.close
+/// [`fail`]: #method.fail
     #[must_use = "if unused the sink may immediately cancel the RPC"]
     DuplexSink,
     DuplexSinkFailure,
@@ -648,7 +648,7 @@ pub struct RpcContext<'a> {
     deadline: Deadline,
 }
 
-impl<'a> RpcContext<'a> {
+impl RpcContext<'_> {
     fn new(ctx: RequestContext, cq: &CompletionQueue) -> RpcContext<'_> {
         RpcContext {
             deadline: ctx.deadline(),

src/cq.rs

@@ -117,13 +117,13 @@ pub struct CompletionQueueRef<'a> {
     queue: &'a CompletionQueue,
 }
 
-impl<'a> CompletionQueueRef<'a> {
+impl CompletionQueueRef<'_> {
     pub fn as_ptr(&self) -> *mut grpc_completion_queue {
         self.queue.handle.cq
     }
 }
 
-impl<'a> Drop for CompletionQueueRef<'a> {
+impl Drop for CompletionQueueRef<'_> {
     fn drop(&mut self) {
         self.queue.handle.unref();
     }

src/metadata.rs

@@ -143,18 +143,18 @@ impl Clone for MetadataBuilder {
 ///
 /// - Request headers
 ///
-///     They are sent by the client at the beginning of a remote call before
-///     any request messages are sent.
+///  They are sent by the client at the beginning of a remote call before
+///  any request messages are sent.
 ///
 /// - Response headers
 ///
-///     They are sent by the server at the beginning of a remote call handler
-///     before any response messages are sent.
+///  They are sent by the server at the beginning of a remote call handler
+///  before any response messages are sent.
 ///
 /// - Response trailers
 ///
-///     They are sent by the server at the end of a remote call along with
-///     resulting call status.
+///  They are sent by the server at the end of a remote call along with
+///  resulting call status.
 ///
 /// Metadata value can be ascii string or bytes. They are distinguish by the
 /// key suffix, key of bytes value should have suffix '-bin'.

src/task/executor.rs

@@ -233,7 +233,7 @@ pub(crate) struct Executor<'a> {
     cq: &'a CompletionQueue,
 }
 
-impl<'a> Executor<'a> {
+impl Executor<'_> {
     pub fn new(cq: &CompletionQueue) -> Executor<'_> {
         Executor { cq }
     }