diff --git a/pallas-chainsync/examples/blocks.rs b/pallas-chainsync/examples/blocks.rs
index 1086503..c2e0d60 100644
--- a/pallas-chainsync/examples/blocks.rs
+++ b/pallas-chainsync/examples/blocks.rs
@@ -1,36 +1,23 @@
-use net2::TcpStreamExt;
-use pallas_txsubmission::NaiveProvider;
-use std::net::TcpStream;
-use std::thread;
-use std::time::Duration;
-
 use pallas_chainsync::{Consumer, Point};
 use pallas_handshake::n2c::{Client, VersionTable};
 use pallas_handshake::MAINNET_MAGIC;
 use pallas_machines::run_agent;
 use pallas_multiplexer::Multiplexer;
+use std::os::unix::net::UnixStream;
 
 fn main() {
     env_logger::init();
 
-    //let bearer = TcpStream::connect("localhost:6000").unwrap();
-    let bearer = TcpStream::connect("relays-new.cardano-mainnet.iohk.io:3001").unwrap();
-
-    bearer.set_nodelay(true).unwrap();
-    bearer.set_keepalive_ms(Some(30_000u32)).unwrap();
+    let bearer = UnixStream::connect("/tmp/node.socket").unwrap();
 
     let mut muxer = Multiplexer::try_setup(bearer, &vec![0, 4, 5]).unwrap();
-    
+
     let (rx, tx) = muxer.use_channel(0);
     let versions = VersionTable::v1_and_above(MAINNET_MAGIC);
     let last = run_agent(Client::initial(versions), rx, &tx).unwrap();
     println!("last hanshake state: {:?}", last);
 
-    let (ts_rx, ts_tx) = muxer.use_channel(4);
-    let ts = NaiveProvider::initial(vec![]);
-    let ts = run_agent(ts, ts_rx, &ts_tx).unwrap();
-    println!("last tx-submission state: {:?}", ts);
-
+    // some random known-point in the chain to use as starting point for the sync
     let known_points = vec![Point(
         43847831u64,
         hex::decode("15b9eeee849dd6386d3770b0745e0450190f7560e5159b1b3ab13b14b2684a45").unwrap(),
diff --git a/pallas-chainsync/examples/headers.rs b/pallas-chainsync/examples/headers.rs
index e314f92..8e3233e 100644
--- a/pallas-chainsync/examples/headers.rs
+++ b/pallas-chainsync/examples/headers.rs
@@ -10,7 +10,6 @@ use pallas_multiplexer::Multiplexer;
 fn main() {
     env_logger::init();
 
-    //let bearer = TcpStream::connect("localhost:6000").unwrap();
     let bearer = TcpStream::connect("relays-new.cardano-mainnet.iohk.io:3001").unwrap();
 
     bearer.set_nodelay(true).unwrap();