diff --git a/sentry/src/transports/thread.rs b/sentry/src/transports/thread.rs index 368ecdd8..80d0e120 100644 --- a/sentry/src/transports/thread.rs +++ b/sentry/src/transports/thread.rs @@ -80,7 +80,7 @@ impl TransportThread { pub fn flush(&self, timeout: Duration) -> bool { let (sender, receiver) = sync_channel(1); let _ = self.sender.send(Task::Flush(sender)); - receiver.recv_timeout(timeout).is_err() + receiver.recv_timeout(timeout).is_ok() } } diff --git a/sentry/src/transports/tokio_thread.rs b/sentry/src/transports/tokio_thread.rs index 5ea1ae5e..9323e482 100644 --- a/sentry/src/transports/tokio_thread.rs +++ b/sentry/src/transports/tokio_thread.rs @@ -96,7 +96,7 @@ impl TransportThread { pub fn flush(&self, timeout: Duration) -> bool { let (sender, receiver) = sync_channel(1); let _ = self.sender.send(Task::Flush(sender)); - receiver.recv_timeout(timeout).is_err() + receiver.recv_timeout(timeout).is_ok() } }