use crate::*;
#[cfg(feature = "parallel")]
use rayon::prelude::*;
mod r#async;
mod ext;
mod input;
mod pipeline;
pub mod filter;
pub use ext::*;
pub use input::Input;
pub use pipeline::*;
pub use r#async::*;
pub trait Filter<T: Type, C: Color, U: Type = T, D: Color = C>: std::fmt::Debug + Sync {
fn schedule(&self) -> Schedule {
Schedule::Pixel
}
fn output_size(&self, _input: &Input<T, C>, dest: &mut Image<U, D>) -> Size {
dest.size()
}
fn compute_at(&self, pt: Point, input: &Input<T, C>, dest: &mut DataMut<U, D>);
fn eval_partial(&self, roi: Region, input: &[&Image<T, C>], output: &mut Image<U, D>) {
let input = Input::new(input);
let iter = output.iter_region_mut(roi);
iter.for_each(|(pt, mut data)| {
self.compute_at(pt, &input, &mut data);
});
}
fn eval_partial_in_place(&self, roi: Region, output: &mut Image<U, D>) {
let input = output as *mut _ as *const _;
let input = unsafe { &[&*input] };
let input = Input::new(input);
output.iter_region_mut(roi).for_each(|(pt, mut data)| {
self.compute_at(pt, &input, &mut data);
});
}
fn eval(&self, input: &[&Image<T, C>], output: &mut Image<U, D>) {
let input = Input::new(input);
output.for_each(|pt, mut data| {
self.compute_at(pt, &input, &mut data);
});
}
fn eval_in_place(&self, output: &mut Image<U, D>) {
let input = output as *mut _ as *const _;
let input = unsafe { &[&*input] };
let input = Input::new(input);
output.for_each(|pt, mut data| {
self.compute_at(pt, &input, &mut data);
});
}
}