Package org.linkedopenactors.rdfpub.client

Class RdfPubClientWebFluxAnonymousDefault

java.lang.Object
org.linkedopenactors.rdfpub.client.RdfPubClientWebFluxAnonymousDefault
All Implemented Interfaces:
RdfPubClientAnonymousWebFlux
public class RdfPubClientWebFluxAnonymousDefault extends Object implements RdfPubClientAnonymousWebFlux
Default implementation of RdfPubClient.
Author:
SofwareEngineering Hauschel

  • Constructor Details

    • RdfPubClientWebFluxAnonymousDefault

      public RdfPubClientWebFluxAnonymousDefault(String rdfPubServerUrl, org.springframework.web.reactive.function.client.WebClient webClient)
      Parameters:
      rdfPubServerUrl - rdfPubServerUrl
      webClient - The webclient to use for http communication.

  • Method Details

    • getServerProfile

      public reactor.core.publisher.Mono<RdfPubServerProfile> getServerProfile()
      Specified by:
      getServerProfile in interface RdfPubClientAnonymousWebFlux

    • read

      public reactor.core.publisher.Mono<org.eclipse.rdf4j.model.Model> read(org.eclipse.rdf4j.model.IRI idOfTheResourceToRead)
      Specified by:
      read in interface RdfPubClientAnonymousWebFlux

    • tupleQueryAsPublic

      public reactor.core.publisher.Flux<org.eclipse.rdf4j.query.BindingSet> tupleQueryAsPublic(String query)
      Specified by:
      tupleQueryAsPublic in interface RdfPubClientAnonymousWebFlux

    • getSparqlRepository2

      public org.eclipse.rdf4j.repository.sparql.SPARQLRepository getSparqlRepository2(org.eclipse.rdf4j.model.IRI sparqlEndpointMono)

    • getSparqlRepository2

      public org.eclipse.rdf4j.repository.sparql.SPARQLRepository getSparqlRepository2(org.eclipse.rdf4j.model.IRI sparqlEndpoint, String token)