trait SparqlRequestFlowBuilder extends SparqlQueryFlowBuilder with SparqlConstructFlowBuilder with SparqlUpdateFlowBuilder
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SparqlRequestFlowBuilder
- SparqlUpdateFlowBuilder
- SparqlConstructFlowBuilder
- SparqlQueryFlowBuilder
- ErrorHandlerSupport
- SparqlClientHelpers
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
type
Sparql = String
- Definition Classes
- SparqlConstructFlowBuilder
Abstract Value Members
-
implicit abstract
val
dispatcher: ExecutionContext
- Definition Classes
- SparqlUpdateFlowBuilder
-
abstract
def
errorHandler: ErrorHandler
- Definition Classes
- ErrorHandlerSupport
-
implicit abstract
val
materializer: ActorMaterializer
- Definition Classes
- SparqlUpdateFlowBuilder → SparqlClientHelpers
-
implicit abstract
val
system: ActorSystem
- Definition Classes
- SparqlUpdateFlowBuilder → SparqlClientHelpers
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
acceptQueryMediaType(queryType: QueryType): MediaType
- Definition Classes
- SparqlClientHelpers
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
deReifyConstructSubGraph(): Flow[Model, Model, NotUsed]
- Definition Classes
- SparqlConstructFlowBuilder
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isSparqlResultsJson(contentType: ContentType): Boolean
- Definition Classes
- SparqlClientHelpers
-
def
makeHttpRequest(endpoint: HttpEndpoint, statement: SparqlStatement): HttpRequest
- Definition Classes
- SparqlClientHelpers
-
def
makeRequestHeaders(endpoint: HttpEndpoint): List[HttpHeader]
- Definition Classes
- SparqlClientHelpers
-
def
mapContentTypeToRdfFormat(contentType: ContentType): RDFFormat
- Definition Classes
- SparqlClientHelpers
-
def
mapRdfFormatToContentType(format: RDFFormat): ContentType
- Definition Classes
- SparqlClientHelpers
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
implicit
val
rawBooleanFromEntityUnmarshaller: FromEntityUnmarshaller[Boolean]
- Definition Classes
- SparqlClientHelpers
-
def
responseToBoolean(response: Tuple2[Try[HttpResponse], _]): Future[Boolean]
Consume the response entity and return a future boolean indicating the success status.
Consume the response entity and return a future boolean indicating the success status.
- Attributes
- protected
- Definition Classes
- SparqlUpdateFlowBuilder
-
lazy val
responseToFailureFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
This flow will also consume the Http response entity if it is received via a valid HTTP response with an HTTP status code and produces a corresponding SparqlErrorResult
This flow will also consume the Http response entity if it is received via a valid HTTP response with an HTTP status code and produces a corresponding SparqlErrorResult
- Definition Classes
- SparqlConstructFlowBuilder
-
val
responseToResultFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
- Definition Classes
- SparqlConstructFlowBuilder
-
def
responseToSparqlResponse(response: (Try[HttpResponse], SparqlRequest)): SparqlResponse
Takes the HttpResponse and makes a SparqlResponse.
Takes the HttpResponse and makes a SparqlResponse.
NB: This function will NOT consume the response entity!!
- Definition Classes
- SparqlClientHelpers
-
lazy val
responseToSuccessFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
This flow will consume the Http response entity and produces a corresponding SparqlModelResult
This flow will consume the Http response entity and produces a corresponding SparqlModelResult
- Definition Classes
- SparqlConstructFlowBuilder
-
def
sparqlConstructFlow(endpointFlow: HttpEndpointFlow[SparqlRequest]): Flow[SparqlRequest, SparqlResponse, NotUsed]
- Definition Classes
- SparqlConstructFlowBuilder
-
def
sparqlQueryFlow(endpointFlow: HttpEndpointFlow[SparqlRequest]): Flow[SparqlRequest, SparqlResponse, Any]
- Definition Classes
- SparqlQueryFlowBuilder
-
def
sparqlRequestFlow(endpointFlow: HttpEndpointFlow[SparqlRequest]): Flow[SparqlRequest, SparqlResponse, NotUsed]
Create a flow of Sparql requests to results.
Create a flow of Sparql requests to results.
- endpointFlow
the HTTP endpoint flow for the Sparql triple store server
-
def
sparqlToRequest(endpoint: HttpEndpoint)(request: SparqlRequest): (HttpRequest, SparqlRequest)
- Definition Classes
- SparqlClientHelpers
-
def
sparqlUpdateFlow(endpointFlow: HttpEndpointFlow[SparqlRequest]): Flow[SparqlRequest, SparqlResponse, NotUsed]
- Definition Classes
- SparqlUpdateFlowBuilder
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
Deprecated Value Members
-
lazy val
responseToPagingModelFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
- Definition Classes
- SparqlConstructFlowBuilder
- Annotations
- @deprecated
- Deprecated