check lock readiness in poll_ready()

vectordotdev · Apr 10, 2023 · 12111d2 · 12111d2
1 parent 9e85fe9
commit 12111d2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/sinks/pulsar/service.rs b/src/sinks/pulsar/service.rs
@@ -83,7 +83,10 @@ impl<Exe: Executor> Service<PulsarRequest> for PulsarService<Exe> {
     type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;
 
     fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
-        Poll::Ready(Ok(()))
+        match self.producer.try_lock() {
+            Ok(_) => Poll::Ready(Ok(())),
+            Err(_) => Poll::Pending,
+        }
     }
 
     fn call(&mut self, request: PulsarRequest) -> Self::Future {