Struct StrictRioSource

pub struct StrictRioSource<T>(pub T);

Wrap a Rio TriplesParser or QuadsParser into a Sophia TripleSource or QuadSource respectivelly.

Tuple Fields

0: T

Trait Implementations

impl<T> QuadSource for StrictRioSource<T>

where T: QuadsParser, T::Error: Error + 'static,

type Quad<'x> = Trusted<Quad<'x>>

The type of quads this source yields.

type Error = <T as QuadsParser>::Error

The type of errors produced by this source.

fn try_for_some_quad<EF, F>(&mut self, f: F) -> StreamResult<bool, T::Error, EF>

where EF: Error, F: FnMut(Self::Quad<'_>) -> Result<(), EF>,

Call f for some quad(s) (possibly zero) from this source, if any.

fn try_for_each_quad<F, E>( &mut self, f: F, ) -> Result<(), StreamError<Self::Error, E>>

where F: FnMut(Self::Quad<'_>) -> Result<(), E>, E: Error,

Call f for all quads from this source.

fn for_some_quad<F>(&mut self, f: &mut F) -> Result<bool, Self::Error>

where F: FnMut(Self::Quad<'_>),

Call f for some quad(s) (possibly zero) from this source, if any.

fn for_each_quad<F>(&mut self, f: F) -> Result<(), Self::Error>

where F: FnMut(Self::Quad<'_>),

Call f for all quads from this source.

fn filter_quads<F>(self, predicate: F) -> FilterQuadSource<Self, F>

where Self: Sized, F: FnMut(&Self::Quad<'_>) -> bool,

Returns a source which uses predicate to determine if an quad should be yielded.

fn filter_map_quads<F, T>(self, filter_map: F) -> FilterMapQuadSource<Self, F>

where Self: Sized, F: FnMut(Self::Quad<'_>) -> Option<T>,

Returns a source that both filters and maps.

fn map_quads<F, T>(self, map: F) -> MapQuadSource<Self, F>

where Self: Sized, F: FnMut(Self::Quad<'_>) -> T,

Returns a source which yield the result of map for each quad.

fn to_triples(self) -> ToTriples<Self>

where Self: Sized,

Convert of quads in this source to triples (stripping the graph name).

fn size_hint_quads(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the source.

fn collect_quads<D>( self, ) -> Result<D, StreamError<Self::Error, <D as Dataset>::Error>>

where Self: Sized, Self::Quad<'x>: for<'x> Quad, D: CollectibleDataset,

Collect these quads into a new dataset.

fn add_to_dataset<D>( self, dataset: &mut D, ) -> Result<usize, StreamError<Self::Error, <D as MutableDataset>::MutationError>>

where D: MutableDataset, Self: Sized, Self::Quad<'x>: for<'x> Quad,

Insert all quads from this source into the given MutableDataset.

impl<T> TripleSource for StrictRioSource<T>

where T: TriplesParser, T::Error: Error + 'static,

type Triple<'x> = Trusted<Triple<'x>>

The type of triples this source yields.

type Error = <T as TriplesParser>::Error

The type of errors produced by this source.

fn try_for_some_triple<EF, F>( &mut self, f: F, ) -> StreamResult<bool, T::Error, EF>

where EF: Error, F: FnMut(Self::Triple<'_>) -> Result<(), EF>,

Call f for some triple(s) (possibly zero) from this source, if any.

fn try_for_each_triple<F, E>( &mut self, f: F, ) -> Result<(), StreamError<Self::Error, E>>

where F: FnMut(Self::Triple<'_>) -> Result<(), E>, E: Error,

Call f for all triples from this source.

fn for_some_triple<F>(&mut self, f: &mut F) -> Result<bool, Self::Error>

where F: FnMut(Self::Triple<'_>),

Call f for some triple(s) (possibly zero) from this source, if any.

fn for_each_triple<F>(&mut self, f: F) -> Result<(), Self::Error>

where F: FnMut(Self::Triple<'_>),

Call f for all triples from this source.

fn filter_triples<F>(self, predicate: F) -> FilterTripleSource<Self, F>

where Self: Sized, F: FnMut(&Self::Triple<'_>) -> bool,

Returns a source which uses predicate to determine if an triple should be yielded.

fn filter_map_triples<F, T>( self, filter_map: F, ) -> FilterMapTripleSource<Self, F>

where Self: Sized, F: FnMut(Self::Triple<'_>) -> Option<T>,

Returns a source that both filters and maps.

fn map_triples<F, T>(self, map: F) -> MapTripleSource<Self, F>

where Self: Sized, F: FnMut(Self::Triple<'_>) -> T,

Returns a source which yield the result of map for each triple.

fn to_quads(self) -> ToQuads<Self>

where Self: Sized,

Convert of triples in this source to quads (belonging to the default graph).

fn size_hint_triples(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the source.

fn collect_triples<G>( self, ) -> Result<G, StreamError<Self::Error, <G as Graph>::Error>>

where Self: Sized, Self::Triple<'x>: for<'x> Triple, G: CollectibleGraph,

Collect these triples into a new graph.

fn add_to_graph<G>( self, graph: &mut G, ) -> Result<usize, StreamError<Self::Error, <G as MutableGraph>::MutationError>>

where G: MutableGraph, Self: Sized, Self::Triple<'x>: for<'x> Triple,

Insert all triples from this source into the given MutableGraph.