Enable flushing for JSON logger

sile · Jul 3, 2021 · 0c60fa7 · 0c60fa7
1 parent 37c3fea
commit 0c60fa7
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 7 deletions.
diff --git a/src/file.rs b/src/file.rs
@@ -154,7 +154,10 @@ impl Build for FileLoggerBuilder {
             }
             #[cfg(feature = "json")]
             Format::Json => {
-                let drain = slog_json::Json::default(self.appender.clone());
+                let drain = slog_json::Json::new(self.appender.clone())
+                    .set_flush(true)
+                    .add_default_keys()
+                    .build();
                 self.common.build_with_drain(drain)
             }
         };

diff --git a/src/terminal.rs b/src/terminal.rs
@@ -103,12 +103,18 @@ impl Build for TerminalLoggerBuilder {
             }
             #[cfg(feature = "json")]
             Format::Json => match self.destination {
-                Destination::Stdout => self
-                    .common
-                    .build_with_drain(slog_json::Json::default(std::io::stdout())),
-                Destination::Stderr => self
-                    .common
-                    .build_with_drain(slog_json::Json::default(std::io::stderr())),
+                Destination::Stdout => self.common.build_with_drain(
+                    slog_json::Json::new(std::io::stdout())
+                        .set_flush(true)
+                        .add_default_keys()
+                        .build(),
+                ),
+                Destination::Stderr => self.common.build_with_drain(
+                    slog_json::Json::new(std::io::stderr())
+                        .set_flush(true)
+                        .add_default_keys()
+                        .build(),
+                ),
             },
         };
         Ok(logger)