type WriteChannel = Sender<(Vec<(Row, Diff)>, Sender<Result<(), StorageError>>)>;