Abstract Protected constructorReadonly beforeActor that must be registered in the bus before this actor.
Readonly busThe bus this actor subscribes to.
Readonly mediatorReadonly nameThe name for this actor.
{<rdf:subject>}
Readonly operationProtected Readonly predicateProtected Static Readonly FACTORYProtected getOptional data: (() => any)Pushes all terms to iterator it that are a solution of object predicate* ?o.
Term of where we start the predicate* search.
Predicate of the *-path.
The graph in which we search for the pattern.
Remembers the objects we've already searched for.
Iterator to push terms to.
Counts how many searches are in progress to close it when needed (when counter == 0).
The results metadata.
Returns an iterator with Bindings of the query subject predicate* ?o or subject predicate+ ?o If graph is a variable, it will also be in those bindings
Term of where we start the predicate* search.
Predicate of the *-path.
Variable of the zeroOrMore-query.
The graph in which we search for the pattern. (Possibly a variable)
The context to pass to sub-opertations
If the path operation is predicate*, otherwise it is predicate+.
Iterator to where all bindings of query should have been pushed.
Find all sources recursively contained in the given path operation.
Pushes all terms to iterator it that are a solution of ?s predicate* ?o.
String representation of subjectVariable
String representation of objectVariable
Term of where we start the predicate* search.
Found solution for an object, start for the new step.
Predicate of the *-path.
The graph in which we search for the pattern.
Remembers solutions for when objectVal is already been calculated, can be reused when same objectVal occurs
Remembers the pairs we've already searched for, can stop searching if so.
Iterator to push terms to.
Counts how many searches are in progress to close it when needed (when counter == 0).
All solutions of query should have been pushed to it by then.
Protected logOptional data: (() => any)Protected logOptional data: (() => any)Protected logOptional data: (() => any)Protected logOptional data: (() => any)Protected logOptional data: (() => any)Protected logOptional data: (() => any)Private predicateRun the given action on this actor.
In most cases, this method should not be called directly. Instead, #runObservable should be called.
The action to run.
A promise that resolves to the run result.
Run the given action on this actor AND invokes the Bus#onRun method.
The action to run.
A promise that resolves to the run result.
Protected Abstract runCheck if this actor can run the given action, without actually running it.
The action to test.
A promise that resolves to the test result.
Static assignAssign a source wrapper to the given operation. The operation is copied and returned.
An operation.
A source wrapper.
Static createCreate an existence resolver for usage within an expression context.
An action context.
A query operation mediator.
The bindings factory.
Static doesCheck if the given shape accepts the given query operation.
A shape to test the query operation against.
A query operation to test.
Optional options: { Additional options to consider.
Optional filterIf additional bindings will be pushed down to the source for filtering.
Optional joinIf additional bindings will be pushed down to the source for joining.
Static getCreate an options object that can be used to construct a expression-evaluator asynchronous evaluator.
An action context.
A query query operation mediator for resolving exists.
The bindings factory.
Protected Static getStatic getGet the logger from the given context.
An optional context.
The logger or undefined.
Static getCreate an options object that can be used to construct a expression-evaluator synchronous evaluator.
An action context.
Optional _mediatorQueryOperation: MediatorQueryOperationAn optional query query operation mediator.
If defined, the existence resolver will be defined as exists.
Static getObtain the query source attached to the given operation.
An algebra operation.
Static getSafely cast a query operation output to a bindings output. This will throw a runtime error if the output is of the incorrect type.
A query operation output.
A bindings query operation output.
Static getSafely cast a query operation output to a boolean output. This will throw a runtime error if the output is of the incorrect type.
A query operation output.
A boolean query operation output.
Static getSafely cast a query operation output to a quads output. This will throw a runtime error if the output is of the incorrect type.
A query operation output.
A quads query operation output.
Static getSafely cast a query operation output to a void output. This will throw a runtime error if the output is of the incorrect type.
A query operation output.
A void query operation output.
Static removeStatic throwThrow an error if the context contains the readOnly flag.
An action context.
Static validateThrow an error if the output type does not match the expected type.
A query operation output.
The expected output type.
An abstract actor that handles Path operations.
Provides multiple helper functions used by the Path operation actors.