Class StreamingQuerySourceRdfJs

constructor

• new StreamingQuerySourceRdfJs(
      store: StreamingStore<Quad>,
      dataFactory: ComunicaDataFactory,
      bindingsFactory: BindingsFactory,
  ): StreamingQuerySourceRdfJs

  Parameters

  • store: StreamingStore<Quad>
  • dataFactory: ComunicaDataFactory
  • bindingsFactory: BindingsFactory

  Returns StreamingQuerySourceRdfJs

store

getSelectorShape

• getSelectorShape(): Promise<FragmentSelectorShape>

  Get the selector type that is supported by this source.

  Returns Promise<FragmentSelectorShape>

halt

• halt(): void

  Returns void

queryBindings

• queryBindings(operation: Operation, context: IActionContext): BindingsStream

  Returns a (possibly lazy) stream that returns all bindings matching the operation.

  Passed operations MUST conform to the query shape exposed by the selector type returned from getSelectorShape. The given operation represents a Linked Data Fragments selector.

  The returned stream MUST expose the property 'metadata' of type MetadataBindings. The implementor is reponsible for handling cases where 'metadata' is being called without the stream being in flow-mode. This metadata object can become invalidated (see metadata.state), in which case the 'metadata' property must and will be updated.

  Parameters

  • operation: Operation
  • context: IActionContext

  Returns BindingsStream

  The resulting bindings stream.

  See

  https://linkeddatafragments.org/specification/linked-data-fragments/#selectors

queryBoolean

• queryBoolean(_operation: Ask, _context: IActionContext): Promise<boolean>

  Returns a promise resolving to the ask response of the given operation.

  This method should only be supported if the selector type returned from getSelectorShape supports ask queries.

  Parameters

  • _operation: Ask
  • _context: IActionContext

  Returns Promise<boolean>

  The resulting ask reply.

queryQuads

• queryQuads(_operation: Operation, _context: IActionContext): AsyncIterator<Quad>

  Returns a (possibly lazy) stream that returns all quads matching the operation.

  This method should only be supported if the selector type returned from getSelectorShape supports construct queries.

  Parameters

  • _operation: Operation
  • _context: IActionContext

  Returns AsyncIterator<Quad>

  The resulting quads stream.

queryVoid

• queryVoid(_operation: Update, _context: IActionContext): Promise<void>

  Returns a promise resolving when the given update operation succeeds.

  This method should only be supported if the selector type returned from getSelectorShape supports update queries.

  Parameters

  • _operation: Update
  • _context: IActionContext

  Returns Promise<void>

  The void response.

resume

• resume(): void

  Returns void

toString

• toString(): string

  Returns a string representation of an object.

  Returns string

StatichasDuplicateVariables

• hasDuplicateVariables(pattern: BaseQuad): boolean

  Parameters

  • pattern: BaseQuad

  Returns boolean

StaticnullifyVariables

• nullifyVariables(
      term: undefined | Term,
      quotedTripleFiltering: boolean,
  ): null | Term

  Parameters

  • term: undefined | Term
  • quotedTripleFiltering: boolean

  Returns null | Term