diff --git a/examples/wallet.rs b/examples/wallet.rs
index 85df9e5..d5f9d1c 100644
--- a/examples/wallet.rs
+++ b/examples/wallet.rs
@@ -13,9 +13,6 @@ const PEERS: &[IpAddr] = &[IpAddr::V4(Ipv4Addr::new(23, 137, 57, 100))];
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    let subscriber = tracing_subscriber::FmtSubscriber::new();
-    tracing::subscriber::set_global_default(subscriber).unwrap();
-
     let desc = "tr([7d94197e/86'/1'/0']tpubDCyQVJj8KzjiQsFjmb3KwECVXPvMwvAxxZGCP9XmWSopmjW3bCV3wD7TgxrUhiGSueDS1MU5X1Vb1YjYcp8jitXc5fXfdC1z68hDDEyKRNr/0/*)";
     let change_desc = "tr([7d94197e/86'/1'/0']tpubDCyQVJj8KzjiQsFjmb3KwECVXPvMwvAxxZGCP9XmWSopmjW3bCV3wD7TgxrUhiGSueDS1MU5X1Vb1YjYcp8jitXc5fXfdC1z68hDDEyKRNr/1/*)";
 
@@ -43,18 +40,19 @@ async fn main() -> anyhow::Result<()> {
 
     tokio::task::spawn(async move { node.run().await });
 
+    // Print logs to the console using the `tracing` crate
+    let logger = TraceLogger::new()?;
+
     tracing::info!(
         "Balance before sync: {} sats",
         wallet.balance().total().to_sat()
     );
 
     // Sync and apply updates. We can do this a continual loop while the "application" is running.
-    // Often this loop would be on a separate "Task" in a Swift app for instance
-    let logger = TraceLogger::new();
+    // Often this would occur on a separate thread than the underlying application user interface.
     loop {
         if let Some(update) = client.update(&logger).await {
             wallet.apply_update(update)?;
-            // Do something here to add more scripts?
             tracing::info!("Tx count: {}", wallet.transactions().count());
             tracing::info!("Balance: {}", wallet.balance().total().to_sat());
             let last_revealed = wallet.derivation_index(KeychainKind::External).unwrap();
diff --git a/src/logger.rs b/src/logger.rs
index ff37cee..563eb06 100644
--- a/src/logger.rs
+++ b/src/logger.rs
@@ -20,7 +20,7 @@
 //! use bdk_kyoto::logger::{NodeMessageHandler, TraceLogger};
 //! use bdk_kyoto::Warning;
 //!
-//! let logger = TraceLogger::new();
+//! let logger = TraceLogger::new().unwrap();
 //! logger.dialog("The node is running".into());
 //! logger.warning(Warning::PeerTimedOut);
 //! ```
@@ -34,6 +34,8 @@ use std::fmt::Debug;
 use kyoto::NodeState;
 use kyoto::Txid;
 use kyoto::Warning;
+#[cfg(feature = "trace")]
+use tracing::subscriber::SetGlobalDefaultError;
 
 /// Handle dialog and state changes from a node with some arbitrary behavior.
 /// The primary purpose of this trait is not to respond to events by persisting changes,
@@ -106,16 +108,22 @@ impl NodeMessageHandler for PrintLogger {
     }
 }
 
-/// Print messages from the node to the console
+/// Print messages from the node to the console using [`tracing`].
 #[cfg(feature = "trace")]
 #[derive(Default, Debug)]
 pub struct TraceLogger {}
 
 #[cfg(feature = "trace")]
 impl TraceLogger {
-    /// Build a new trace logger
-    pub fn new() -> Self {
-        Self {}
+    /// Build a new trace logger. This constructor will initialize the [`tracing::subscriber`] globally.
+    ///
+    /// ## Errors
+    ///
+    /// If [`TraceLogger::new`] has already been called.
+    pub fn new() -> Result<Self, SetGlobalDefaultError> {
+        let subscriber = tracing_subscriber::FmtSubscriber::new();
+        tracing::subscriber::set_global_default(subscriber)?;
+        Ok(Self {})
     }
 }