diff --git a/src/writers/file_log_writer/state_handle.rs b/src/writers/file_log_writer/state_handle.rs
index b0fdad2..8fb8f11 100644
--- a/src/writers/file_log_writer/state_handle.rs
+++ b/src/writers/file_log_writer/state_handle.rs
@@ -177,7 +177,7 @@ impl StateHandle {
             StateHandle::Sync(handle) => {
                 let mut state_guard = handle.am_state.lock().map_err(|_e| io_err("Poison"))?;
                 let state = &mut *state_guard;
-                state.write_buffer(buffer).map(|_| buffer.len())
+                state.write_buffer(buffer).map(|()| buffer.len())
             }
             #[cfg(feature = "async")]
             StateHandle::Async(handle) => {
diff --git a/src/writers/syslog_writer.rs b/src/writers/syslog_writer.rs
index cd4c0ff..4c512a6 100644
--- a/src/writers/syslog_writer.rs
+++ b/src/writers/syslog_writer.rs
@@ -403,7 +403,8 @@ impl Write for SyslogConnector {
             #[cfg(target_family = "unix")]
             Self::Stream(ref mut w) => {
                 // todo: reconnect if conn is broken
-                w.write(buf).and_then(|sz| w.write_all(&[0; 1]).map(|_| sz))
+                w.write(buf)
+                    .and_then(|sz| w.write_all(&[0; 1]).map(|()| sz))
             }
             Self::Tcp(ref mut w) => {
                 // todo: reconnect if conn is broken