diff --git a/src/rpu.rs b/src/rpu.rs
index adc5f2f5eb..36dd636964 100644
--- a/src/rpu.rs
+++ b/src/rpu.rs
@@ -31,7 +31,7 @@ impl Rpu {
         }
     }
 
-    pub fn write_service<W: Write + Send + 'static>(
+    fn write_service<W: Write + Send + 'static>(
         accounting_stage: Arc<AccountingStage>,
         request_processor: Arc<RequestProcessor>,
         exit: Arc<AtomicBool>,
@@ -49,23 +49,6 @@ impl Rpu {
         })
     }
 
-    pub fn drain_service(
-        accounting_stage: Arc<AccountingStage>,
-        request_processor: Arc<RequestProcessor>,
-        exit: Arc<AtomicBool>,
-    ) -> JoinHandle<()> {
-        spawn(move || {
-            let entry_writer = EntryWriter::new(&accounting_stage, &request_processor);
-            loop {
-                let _ = entry_writer.drain_entries();
-                if exit.load(Ordering::Relaxed) {
-                    info!("drain_service exiting");
-                    break;
-                }
-            }
-        })
-    }
-
     /// Create a UDP microservice that forwards messages the given Rpu.
     /// This service is the network leader
     /// Set `exit` to shutdown its threads.
diff --git a/src/tvu.rs b/src/tvu.rs
index 37f88e17f9..b4feb477bb 100644
--- a/src/tvu.rs
+++ b/src/tvu.rs
@@ -32,7 +32,7 @@ impl Tvu {
         }
     }
 
-    pub fn drain_service(
+    fn drain_service(
         accounting_stage: Arc<AccountingStage>,
         request_processor: Arc<RequestProcessor>,
         exit: Arc<AtomicBool>,