Merge pull request #113 from influxdata/cancel-safety

feat: producer cancellation and panic safety

Author: kodiakhq[bot]

Cargo.toml

@@ -33,7 +33,7 @@ rustls = { version = "0.20", optional = true }
 snap = { version = "1", optional = true }
 thiserror = "1.0"
 time = "0.3"
-tokio = { version = "1.14", default-features = false, features = ["io-util", "net", "rt", "sync", "time"] }
+tokio = { version = "1.14", default-features = false, features = ["io-util", "net", "rt", "sync", "time", "macros"] }
 tokio-rustls = { version = "0.23", optional = true }
 tracing = "0.1"
 zstd = { version = "0.10", optional = true }

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "1.58.1"
+channel = "1.59"
 components = [ "rustfmt", "clippy" ]