Struct GraphORMMeta 

pub struct GraphORMMeta<T>
where
    T: Debug + PartialEq,
{ /* private fields */ }

A descriptor to track meta information about the serialisation of some target on the graph.

This is necessary because simply keeping the target object would cause loss of information. For example, if a struct is deserialised from a graph (e.g. by calling GraphORM::deserialize), the original subject needs to be noted.

Implementations

impl<T> GraphORMMeta<T>

where T: GraphORM + Unpin + Debug + PartialEq + Sync + Send,

pub fn new(thing: T) -> Self

Wrap a target into the descriptor.

This function consumes the target and stores it.

pub fn into_deref(self) -> T

Unwrap the target.

This operation consumes the meta descriptor, thus causing any meta-information to be lost. Serializing the target later will require to re-create a valid [GraphORMMeta] wrtapper.

pub fn with_subject(self, subject: Arc<Term>) -> Self

Add a pre-defined subject to the descriptor.

Subsequent serialisations will use this subject.

pub fn fixate_subject(&mut self) -> Result<(), GraphORMError>

Fixate the subject generated by the target.

This calls GraphORM::rdf_subject once and stores the generated subject for later re-use.

If the subject mode already is SubjectMode::Static, this function does not change the subject.

pub fn subject(&self) -> Result<Arc<Term>, GraphORMError>

pub fn serialize_stream( &self, ) -> Result<impl Stream<Item = Arc<Triple>> + Unpin + Send + use<'_, T>, GraphORMError>

Serialise the target into a stream of triples.

This is a proxy for GraphORM::serialize_stream of the target, injecting the desired subject.

pub async fn serialize( &self, graph: &mut impl Graph, ) -> Result<(), GraphORMError>

Serialize the target into an existing Graph.

This method calls the Graph::merge_stream method, passing the stream of triples for the target to it.

Trait Implementations

impl<T> Clone for GraphORMMeta<T>

where T: Debug + PartialEq + Clone,

fn clone(&self) -> GraphORMMeta<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for GraphORMMeta<T>

where T: Debug + PartialEq + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Deref for GraphORMMeta<T>

where T: Debug + PartialEq,

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for GraphORMMeta<T>

where T: Debug + PartialEq,

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T> Graph for GraphORMMeta<T>

where T: GraphORM + Unpin + Debug + PartialEq + Sync + Send,

type View<'g> = &'g GraphORMMeta<T> where Self: 'g

async fn view(&self) -> Self::View<'_>

fn add( &mut self, triple: Arc<Triple>, ) -> impl Future<Output = Result<(), GraphError>> + Send

fn remove( &mut self, triple: TripleRef<'_>, ) -> impl Future<Output = Result<(), GraphError>> + Send

fn clear(&mut self) -> impl Future<Output = Result<(), GraphError>> + Send

fn merge<G>( &mut self, source_graph: G, ) -> impl Future<Output = Result<(), GraphError>> + Send

where G: GraphView,

fn merge_stream<S, E>( &mut self, stream: S, ) -> impl Future<Output = Result<(), GraphError>> + Send

where S: Stream<Item = Result<Arc<Triple>, E>> + Unpin + Send, GraphError: From<E>, E: Send,

impl<'a, T> GraphView for &'a GraphORMMeta<T>

where T: GraphORM + Unpin + Debug + PartialEq + Sync + Send + 'a,

type Stream = Pin<Box<dyn Stream<Item = Result<Arc<Triple>, GraphError>> + Send + Unpin + 'a>>

type Filter<FilterType> = DefaultFilter<&'a GraphORMMeta<T>, FilterType> where FilterType: TripleFilter + Send + Sync + Unpin + Clone

type Matches<MatchesType> = DefaultMatches<MatchesType, &'a GraphORMMeta<T>> where MatchesType: Matches + Unpin

type SubjectStream<'stream> = Map<<<&'a GraphORMMeta<T> as GraphView>::Matches<(Option<&'stream Term>, Option<&'stream Term>, Option<&'stream Term>)> as GraphView>::Stream, fn(Result<Arc<Triple>, GraphError>) -> Result<Arc<Term>, GraphError>>

type PredicateStream<'stream> = Map<<<&'a GraphORMMeta<T> as GraphView>::Matches<(Option<&'stream Term>, Option<&'stream Term>, Option<&'stream Term>)> as GraphView>::Stream, fn(Result<Arc<Triple>, GraphError>) -> Result<Arc<Term>, GraphError>>

type ObjectStream<'stream> = Map<<<&'a GraphORMMeta<T> as GraphView>::Matches<(Option<&'stream Term>, Option<&'stream Term>, Option<&'stream Term>)> as GraphView>::Stream, fn(Result<Arc<Triple>, GraphError>) -> Result<Arc<Term>, GraphError>>

type SubjectStreamDedup<'stream> = DedupStream<<&'a GraphORMMeta<T> as GraphView>::SubjectStream<'stream>, Arc<Term>>

type ObjectStreamDedup<'stream> = DedupStream<<&'a GraphORMMeta<T> as GraphView>::ObjectStream<'stream>, Arc<Term>>

type PredicateStreamDedup<'stream> = DedupStream<<&'a GraphORMMeta<T> as GraphView>::PredicateStream<'stream>, Arc<Term>>

type CBD<TermType> = CBD<&'a GraphORMMeta<T>, TermType> where TermType: AsRef<Term> + Clone + Send

async fn stream(self) -> Result<Self::Stream, GraphError>

async fn filter<FilterType>( self, filter: FilterType, ) -> Result<Self::Filter<FilterType>, GraphError>

where FilterType: TripleFilter + Send + Sync + Unpin + Clone,

async fn matches<MatchesType>( self, matches: MatchesType, limit: Option<usize>, ) -> Result<Self::Matches<MatchesType>, GraphError>

where MatchesType: Matches + Unpin,

async fn subjects<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::SubjectStream<'stream>, GraphError>

async fn predicates<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::PredicateStream<'stream>, GraphError>

async fn objects<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::ObjectStream<'stream>, GraphError>

async fn subjects_dedup<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::SubjectStreamDedup<'stream>, GraphError>

async fn objects_dedup<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::ObjectStreamDedup<'stream>, GraphError>

async fn predicates_dedup<'stream>( self, arg1: Option<&'stream Term>, arg2: Option<&'stream Term>, limit: Option<usize>, ) -> Result<Self::PredicateStreamDedup<'stream>, GraphError>

fn cbd<TermType>( self, subject: TermType, ) -> impl Future<Output = Result<Self::CBD<TermType>, GraphError>>

where TermType: AsRef<Term> + Clone + Send,

Example

fn describe( self, subject: &Term, limit: Option<usize>, ) -> impl Future<Output = Result<Self::Matches<SubjectMatch<'_>>, GraphError>> + Send

fn subject( self, predicate: Option<&Term>, object: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn predicate( self, subject: Option<&Term>, object: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn object( self, subject: Option<&Term>, predicate: Option<&Term>, ) -> impl Future<Output = Result<Option<Arc<Term>>, GraphError>> + Send

fn contains( self, triple: TripleRef<'_>, ) -> impl Future<Output = Result<bool, GraphError>> + Send

fn isomorphic<G2>( self, other: G2, ) -> impl Future<Output = Result<bool, GraphError>> + Send

where G2: GraphView,

fn ground(self) -> impl Future<Output = Result<bool, GraphError>> + Send

Checks whether graph is ground as defined by RDF Concepts and Abstract Syntax

fn default_triple_size_hint() -> usize

fn default_buf_size_hint() -> usize

fn triple_size_hint(&self) -> usize

fn buf_size_hint(&self) -> usize

impl<T> PartialEq for GraphORMMeta<T>

where T: Debug + PartialEq + PartialEq,

fn eq(&self, other: &GraphORMMeta<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> StructuralPartialEq for GraphORMMeta<T>

where T: Debug + PartialEq,