Struct rio_turtle::TriGParser

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

A TriG streaming parser.

It implements the QuadParser trait.

Count the number of of people using the QuadParser API:

use rio_turtle::TriGParser;
use rio_api::parser::QuadParser;
use rio_api::model::NamedNode;

let file = b"@prefix schema: <http://schema.org/> .
<http://example/> {
    <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;
TriGParser::new(file.as_ref(), "").unwrap().parse_all(&mut |t| {
    if t.predicate == rdf_type && t.object == schema_person.into() {
        count += 1;
    }
}).unwrap();
assert_eq!(2, count)

Methods

impl<R: BufRead> TriGParser<R>

pub fn new(reader: R, base_iri: &str) -> Result<Self, TurtleError>

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

The base IRI might be empty to state there is no base URL.

Trait Implementations

impl<R: BufRead> QuadParser for TriGParser<R>

type Error = TurtleError

fn parse_step(
    &mut self,
    on_quad: &mut impl FnMut(Quad)
) -> Result<(), TurtleError>

Parses a small chunk of the file and calls on_quad each time a new triple is read.

fn is_end(&self) -> bool

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

fn parse_all<impl FnMut(Quad) -> ()>(
    &mut self,
    on_quad: &mut impl FnMut(Quad) -> ()
) -> Result<(), Self::Error> where
    impl FnMut(Quad) -> (): FnMut(Quad), 

Parses the complete file and calls on_quad each time a new quad is read.

fn into_iter<T, E, F>(
    self,
    convert_quad: F
) -> QuadsParserIterator<T, E, F, Self> where
    E: From<Self::Error>,
    F: FnMut(Quad) -> Result<T, E>, 

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