Struct RDFStream 

pub struct RDFStream {
    pub name: String,
    /* private fields */
}

Represents an RDF stream that feeds data into a window

Fields

name: String

Implementations

impl RDFStream

pub fn new(name: String, window_sender: Sender<(QuadContainer, String)>) -> Self

pub fn add(&self, container: QuadContainer) -> Result<(), String>

Add a quad container to the stream

pub fn add_quads(&self, quads: Vec<Quad>, timestamp: i64) -> Result<(), String>

Add a set of quads with a timestamp to the stream

Trait Implementations

impl Clone for RDFStream

fn clone(&self) -> RDFStream

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.