trait SparqlConstructFlowBuilder extends SparqlClientHelpers with ErrorHandlerSupport

Linear Supertypes
ErrorHandlerSupport, SparqlClientHelpers, AnyRef, Any
Known Subclasses
SparqlRequestFlowBuilder
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SparqlConstructFlowBuilder
  2. ErrorHandlerSupport
  3. SparqlClientHelpers
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. type Sparql = String

Abstract Value Members

  1. implicit abstract val dispatcher: ExecutionContext
  2. abstract def errorHandler: ErrorHandler
    Definition Classes
    ErrorHandlerSupport
  3. implicit abstract val materializer: ActorMaterializer
    Definition Classes
    SparqlConstructFlowBuilder → SparqlClientHelpers
  4. implicit abstract val system: ActorSystem
    Definition Classes
    SparqlConstructFlowBuilder → SparqlClientHelpers

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def acceptQueryMediaType(queryType: QueryType): MediaType
    Definition Classes
    SparqlClientHelpers
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. def deReifyConstructSubGraph(): Flow[Model, Model, NotUsed]
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. def isSparqlResultsJson(contentType: ContentType): Boolean
    Definition Classes
    SparqlClientHelpers
  15. def makeHttpRequest(endpoint: HttpEndpoint, statement: SparqlStatement): HttpRequest
    Definition Classes
    SparqlClientHelpers
  16. def makeRequestHeaders(endpoint: HttpEndpoint): List[HttpHeader]
    Definition Classes
    SparqlClientHelpers
  17. def mapContentTypeToRdfFormat(contentType: ContentType): RDFFormat
    Definition Classes
    SparqlClientHelpers
  18. def mapRdfFormatToContentType(format: RDFFormat): ContentType
    Definition Classes
    SparqlClientHelpers
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. implicit val rawBooleanFromEntityUnmarshaller: FromEntityUnmarshaller[Boolean]
    Definition Classes
    SparqlClientHelpers
  23. 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

  24. val responseToResultFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
  25. 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
  26. lazy val responseToSuccessFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]

    This flow will consume the Http response entity and produces a corresponding SparqlModelResult

  27. def sparqlConstructFlow(endpointFlow: HttpEndpointFlow[SparqlRequest]): Flow[SparqlRequest, SparqlResponse, NotUsed]
  28. def sparqlToRequest(endpoint: HttpEndpoint)(request: SparqlRequest): (HttpRequest, SparqlRequest)
    Definition Classes
    SparqlClientHelpers
  29. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  30. def toString(): String
    Definition Classes
    AnyRef → Any
  31. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Deprecated Value Members

  1. lazy val responseToPagingModelFlow: Flow[(Try[HttpResponse], SparqlRequest), SparqlResult, NotUsed]
    Annotations
    @deprecated
    Deprecated

Inherited from ErrorHandlerSupport

Inherited from SparqlClientHelpers

Inherited from AnyRef

Inherited from Any

Ungrouped