code cleanup
This commit is contained in:
@@ -1,9 +1,8 @@
|
|||||||
use std::{collections::HashMap, fs, path::Path};
|
use std::{collections::HashMap, path::Path};
|
||||||
|
|
||||||
use crate::app::{
|
use crate::app::{
|
||||||
builder::{asciidoctor::{AsciiDoctorDocsBuilder, AsciiDoctorSlideBuilder}, Builder},
|
builder::{asciidoctor::{AsciiDoctorDocsBuilder, AsciiDoctorSlideBuilder}, Builder},
|
||||||
fs_util,
|
fs_util,
|
||||||
rx::Observable,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
use super::traits::Command;
|
use super::traits::Command;
|
||||||
|
|||||||
@@ -15,14 +15,6 @@ impl RecursivePathFetch {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn new(path: String) -> Self {
|
|
||||||
return Self {
|
|
||||||
paths: vec![],
|
|
||||||
ends_with: "".to_string(),
|
|
||||||
path
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn fetch(&mut self) -> Result<Vec<String>, String> {
|
pub fn fetch(&mut self) -> Result<Vec<String>, String> {
|
||||||
if let Err(error) = self.read_dir(self.path.clone()) {
|
if let Err(error) = self.read_dir(self.path.clone()) {
|
||||||
return Err(error);
|
return Err(error);
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
mod commands;
|
mod commands;
|
||||||
pub mod builder;
|
pub mod builder;
|
||||||
pub mod rx;
|
|
||||||
pub mod fs_util;
|
pub mod fs_util;
|
||||||
|
|
||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
|
|||||||
@@ -1,24 +0,0 @@
|
|||||||
type Subscriber<T> = fn(value: T) -> ();
|
|
||||||
|
|
||||||
pub struct Observable<T: Copy> {
|
|
||||||
subscriber: Vec<Subscriber<T>>
|
|
||||||
}
|
|
||||||
|
|
||||||
impl<T: Copy> Observable<T> {
|
|
||||||
|
|
||||||
pub fn new() -> Observable<T> {
|
|
||||||
return Observable {
|
|
||||||
subscriber: Vec::new(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn next(&self, value: T) {
|
|
||||||
for callback in &self.subscriber {
|
|
||||||
callback(value);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn subscribe(&mut self, subscriber: Subscriber<T>) {
|
|
||||||
self.subscriber.push(subscriber);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user