Struct fluent_data::streamer::Streamer

pub struct Streamer<In, Out>where
    In: Iterator<Item = Result<String, Box<dyn Error>>>,
    Out: FnMut(String) -> Result<(), Box<dyn Error>>,{ /* private fields */ }

Reads data form In source and writes model to Out sink.

use std::{error::Error, io};

use fluent_data::{algorithm::Algo, model::Model, space, streamer::{Streamer, self}};

fn main() -> Result<(), Box<dyn Error>> {
    let algo = Algo::new(space::euclid_dist, space::real_combine);
    let mut model = Model::new(space::euclid_dist);
    let (points, write) = streamer::stdio();
    let streamer = Streamer::new(points, write);
    Streamer::run(streamer, algo, &mut model)?;
    Ok(())
}

Implementations

impl<In, Out> Streamer<In, Out>where
    In: Iterator<Item = Result<String, Box<dyn Error>>>,
    Out: FnMut(String) -> Result<(), Box<dyn Error>>,

pub fn new(points: In, write: Out) -> Self

builds a new streamer instance.

pub fn run<Point: PartialEq + Serialize + DeserializeOwned + 'static>(
    streamer: Streamer<In, Out>,
    algo: Algo<Point>,
    model: &mut Model<Point>
) -> Result<(), Box<dyn Error>>

Infinitely reads points from In source and write model changes to Out sink.