Struct rio_turtle::TurtleParser

pub struct TurtleParser<R: BufRead> { /* fields omitted */ }

A Turtle streaming parser.

It implements the TriplesParser trait.

Count the number of people using the TriplesParser API:

use rio_turtle::{TurtleParser, TurtleError};
use rio_api::parser::TriplesParser;
use rio_api::model::NamedNode;

let file = b"@prefix schema: <http://schema.org/> .
<http://example.com/foo> a schema:Person ;
    schema:name  \"Foo\" .
<http://example.com/bar> a schema:Person ;
    schema:name  \"Bar\" .";

let rdf_type = NamedNode { iri: "http://www.w3.org/1999/02/22-rdf-syntax-ns#type" };
let schema_person = NamedNode { iri: "http://schema.org/Person" };
let mut count = 0;
TurtleParser::new(file.as_ref(), None).parse_all(&mut |t| {
    if t.predicate == rdf_type && t.object == schema_person.into() {
        count += 1;
    }
    Ok(()) as Result<(), TurtleError>
})?;
assert_eq!(2, count);

Implementations

impl<R: BufRead> TurtleParser<R>

pub fn new(reader: R, base_iri: Option<Iri<String>>) -> Self

Builds the parser from a BufRead implementation, and a base IRI for relative IRI resolution.

Trait Implementations

impl<B: BufRead> TripleSource for TurtleParser<B>

type Error = <TurtleParser<B> as TriplesParser>::Error

The type of errors produced by this source.

type Triple = ScopedRioSourceTriple

Determine the type of Triples that this triple source yields. (see streaming_mode

fn try_for_some_triple<F, EF>(
    &mut self,
    f: &mut F
) -> StreamResult<bool, Self::Error, EF> where
    F: FnMut(StreamedTriple<'_, Self::Triple>) -> Result<(), EF>,
    EF: Error, 

Call f for at least one triple from this triple source, if any.

pub fn try_for_each_triple<F, E>(
    &mut self,
    f: F
) -> Result<(), StreamError<Self::Error, E>> where
    E: Error,
    F: FnMut(StreamedTriple<'_, Self::Triple>) -> Result<(), E>, 

Call f for all triples from this triple source.

pub fn for_some_triple<F>(&mut self, f: &mut F) -> Result<bool, Self::Error> where
    F: FnMut(StreamedTriple<'_, Self::Triple>), 

Call f for at least one triple from this triple source, if any.

pub fn for_each_triple<F>(&mut self, f: F) -> Result<(), Self::Error> where
    F: FnMut(StreamedTriple<'_, Self::Triple>), 

Call f for all triples from this triple source.

pub fn filter_triples<F>(self, filter: F) -> FilterSource<Self, F> where
    F: FnMut(&StreamedTriple<'_, Self::Triple>) -> bool, 

Creates a triple source which uses a closure to determine if a triple should be yielded.

pub fn filter_map_triples<F, T>(self, filter_map: F) -> FilterMapSource<Self, F> where
    F: FnMut(StreamedTriple<'_, Self::Triple>) -> Option<T>, 

Creates a triple source that both filters and maps.

pub fn map_triples<F, T>(self, map: F) -> MapSource<Self, F> where
    F: FnMut(StreamedTriple<'_, Self::Triple>) -> T, 

Takes a closure and creates triple source which yield the result of that closure for each triple.

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

Returns the bounds on the remaining length of the triple source.

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

Collect these triples into a new graph.

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

Insert all triples from this source into the given graph.

impl<R: BufRead> TriplesParser for TurtleParser<R>

type Error = TurtleError

fn parse_step<E: From<TurtleError>>(
    &mut self,
    on_triple: &mut impl FnMut(Triple<'_>) -> Result<(), E>
) -> Result<(), E>

Parses a small chunk of the file and calls on_triple each time a new triple is read. (A “small chunk” could be a line for an N-Triples parser.)

fn is_end(&self) -> bool

Returns true if the file has been completely consumed by the parser.

pub fn parse_all<E>(
    &mut self,
    on_triple: &mut impl FnMut(Triple<'_>) -> Result<(), E>
) -> Result<(), E> where
    E: From<Self::Error>, 

Parses the complete file and calls on_triple each time a new triple is read.

pub fn into_iter<T, E, F>(
    self,
    convert_triple: F
) -> TriplesParserIterator<T, E, F, Self> where
    E: From<Self::Error>,
    F: FnMut(Triple<'_>) -> Result<T, E>, 

Converts the parser into a Result<T, E> iterator.