summaryrefslogtreecommitdiffstats
path: root/src/event_stream.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/event_stream.rs')
-rw-r--r--src/event_stream.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/event_stream.rs b/src/event_stream.rs
index 42d762f..429090a 100644
--- a/src/event_stream.rs
+++ b/src/event_stream.rs
@@ -2,7 +2,7 @@ use std::io;
use crate::{errors::Result, prelude::*, Error};
use futures::{stream::try_unfold, TryStream, TryStreamExt};
-use log::{as_debug, as_serde, debug, error, info, trace};
+use log::{debug, error, info, trace};
use reqwest::Response;
use tokio::io::AsyncBufReadExt;
use tokio_util::io::StreamReader;
@@ -17,7 +17,7 @@ pub fn event_stream(
client: &Mastodon,
) -> impl TryStream<Ok = (Event, Mastodon), Error = Error> + '_ {
let stream = StreamReader::new(response.bytes_stream().map_err(|err| {
- error!(err = as_debug!(err); "error reading stream");
+ error!(err:? = err; "error reading stream");
io::Error::new(io::ErrorKind::BrokenPipe, format!("{err:?}"))
}));
let lines_iter = stream.lines();
@@ -32,7 +32,7 @@ pub fn event_stream(
}
lines.push(line);
if let Ok(event) = make_event(&lines) {
- info!(event = as_serde!(event), location = location; "received event");
+ info!(event:serde = event, location = location; "received event");
lines.clear();
return Ok(Some(((event, client.clone()), this)));
} else {