From a7ffcba0e565b9f54fc27cc8fca796d4e1d645e0 Mon Sep 17 00:00:00 2001 From: Jonathan Strong Date: Thu, 13 Jun 2019 22:45:30 -0400 Subject: [PATCH] adds InfluxWriter::is_full --- src/influx.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/influx.rs b/src/influx.rs index d2f9e27..6b32ded 100644 --- a/src/influx.rs +++ b/src/influx.rs @@ -331,6 +331,8 @@ impl InfluxWriter { self.tx.clone() } + pub fn is_full(&self) -> bool { self.tx.is_full() } + pub fn placeholder() -> Self { let (tx, _) = bounded(1024); Self {