How to use the @comunica/bus-rdf-join.ActorRdfJoin.join function in @comunica/bus-rdf-join
To help you get started, we’ve selected a few @comunica/bus-rdf-join examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
comunica / comunica / packages / actor-query-operation-leftjoin-nestedloop / lib / ActorQueryOperationLeftJoinNestedLoop.ts View on Github 
transform: async (innerItem: Bindings, nextInner: any) => {
const joinedBindings = ActorRdfJoin.join(outerItem, innerItem);
if (!joinedBindings) { nextInner(); return; }
if (!pattern.expression) {
joinedStream._push({ joinedBindings, result: true });
nextInner();
return;
}
try {
const result = await evaluator.evaluateAsEBV(joinedBindings);
joinedStream._push({ joinedBindings, result });
} catch (err) {
if (!isExpressionError(err)) {
bindingsStream.emit('error', err);
}
}
nextInner();
},@comunica/bus-rdf-join
A comunica bus for rdf-join events.
