We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
let _
1 parent 8f2acc1 commit fee5945Copy full SHA for fee5945
graph/src/log/elastic.rs
@@ -262,7 +262,7 @@ impl ElasticDrain {
262
let client = Client::new();
263
let logger_for_err = flush_logger.clone();
264
265
- let _ = client
+ client
266
.post(batch_url)
267
.header("Content-Type", "application/json")
268
.basic_auth(
@@ -272,7 +272,8 @@ impl ElasticDrain {
272
.body(batch_body)
273
.send()
274
.and_then(|response| async { response.error_for_status() })
275
- .map_err(move |e| {
+ .map_ok(|_| ())
276
+ .unwrap_or_else(move |e| {
277
// Log if there was a problem sending the logs
278
error!(
279
logger_for_err,
0 commit comments