From fab2413741cb3ddb569233dc25287287aadc4cd2 Mon Sep 17 00:00:00 2001
From: Wolfgang Bumiller <w.bumiller@proxmox.com>
Date: Wed, 10 Jun 2020 10:42:24 +0200
Subject: [PATCH] catalog: remove unused SenderWriter

Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
---
 src/backup/catalog.rs | 28 ----------------------------
 1 file changed, 28 deletions(-)

diff --git a/src/backup/catalog.rs b/src/backup/catalog.rs
index 6fb377bc..6f6e3a7b 100644
--- a/src/backup/catalog.rs
+++ b/src/backup/catalog.rs
@@ -8,12 +8,10 @@ use anyhow::{bail, format_err, Error};
 use chrono::offset::{TimeZone, Local};
 
 use pathpatterns::{MatchList, MatchType};
-use proxmox::sys::error::io_err_other;
 use proxmox::tools::io::ReadExt;
 
 use crate::backup::file_formats::PROXMOX_CATALOG_FILE_MAGIC_1_0;
 use crate::pxar::catalog::BackupCatalogWriter;
-use crate::tools::runtime::block_on;
 
 #[repr(u8)]
 #[derive(Copy,Clone,PartialEq)]
@@ -400,32 +398,6 @@ impl <W: Write> BackupCatalogWriter for CatalogWriter<W> {
     }
 }
 
-// fixme: move to somehere else?
-/// Implement Write to tokio mpsc channel Sender
-pub struct SenderWriter(tokio::sync::mpsc::Sender<Result<Vec<u8>, Error>>);
-
-impl SenderWriter {
-    pub fn new(sender: tokio::sync::mpsc::Sender<Result<Vec<u8>, Error>>) -> Self {
-        Self(sender)
-    }
-}
-
-impl Write for SenderWriter {
-    fn write(&mut self, buf: &[u8]) -> Result<usize, std::io::Error> {
-        block_on(async move {
-            self.0
-                .send(Ok(buf.to_vec()))
-                .await
-                .map_err(io_err_other)
-                .and(Ok(buf.len()))
-        })
-    }
-
-    fn flush(&mut self) -> Result<(), std::io::Error> {
-        Ok(())
-    }
-}
-
 /// Read Catalog files
 pub struct CatalogReader<R> {
     reader: R,