STTP HTTP & WebSocket client message transport plugin.
Uses the supplied RPC request as HTTP request body and returns HTTP response body as a result.
Type parameters
- Effect
-
effect type
Value parameters
- backend
-
STTP backend
- effectSystem
-
effect system plugin
- method
-
HTTP request method
- url
-
remote API HTTP or WebSocket URL
Attributes
Members list
Value members
Inherited methods
Sends a request to a remote endpoint and retrieves the response.
Sends a request to a remote endpoint and retrieves the response.
An optional request context is used to supply additional information needed to send the request.
Value parameters
- mediaType
-
message media (MIME) type.
- requestBody
-
request message body
- requestContext
-
request context
- requestId
-
request correlation identifier
Attributes
- Returns
-
response message and context
- Definition Classes
-
[String](sttpRequest.uri.toString)) result.fold[Effect[Tuple2[Array[Byte],Context]]](((error:Throwable)=>{ SttpClientBase.this.log.failedReceiveResponse(error,responseProperties,protocol.name) SttpClientBase.this.effectSystem.failed[Tuple2[Array[Byte],Context]](error) }),((response:Response[Array[Byte]])=>{ SttpClientBase.this.log.receivedResponse(responseProperties.+[String](ArrowAssoc[String]("Status").->[String](response.code.toString)),protocol.name) SttpClientBase.this.effectSystem.successful[Tuple2[Array[Byte],Context]](ArrowAssoc[Array[Byte]](response.body).->[HttpContext[TransportContext]](SttpClientBase.this.getResponseContext(response))) })) }))(SttpClientBase.this.system)))(SttpClientBase.this.system) }">SttpClientBase -> ClientTransport
- Inherited from:
- [String](sttpRequest.uri.toString)) result.fold[Effect[Tuple2[Array[Byte],Context]]](((error:Throwable)=>{ SttpClientBase.this.log.failedReceiveResponse(error,responseProperties,protocol.name) SttpClientBase.this.effectSystem.failed[Tuple2[Array[Byte],Context]](error) }),((response:Response[Array[Byte]])=>{ SttpClientBase.this.log.receivedResponse(responseProperties.+[String](ArrowAssoc[String]("Status").->[String](response.code.toString)),protocol.name) SttpClientBase.this.effectSystem.successful[Tuple2[Array[Byte],Context]](ArrowAssoc[Array[Byte]](response.body).->[HttpContext[TransportContext]](SttpClientBase.this.getResponseContext(response))) })) }))(SttpClientBase.this.system)))(SttpClientBase.this.system) }">SttpClientBase (hidden)
Closes this client transport freeing the underlying resources.
Closes this client transport freeing the underlying resources.
Attributes
- Returns
-
nothing
- Definition Classes
- Inherited from:
- SttpClientBase (hidden)
Creates default request context based on the configuration of this client transport.
Creates default request context based on the configuration of this client transport.
Attributes
- Returns
-
request context based on the configuration of this client transport
- Definition Classes
- Inherited from:
- SttpClientBase (hidden)
Initializes this client to invoke remote APIs.
Initializes this client to invoke remote APIs.
Attributes
- Returns
-
active RPC server
- Definition Classes
- Inherited from:
- SttpClientBase (hidden)
Attributes
- Inherited from:
- Product
Attributes
- Inherited from:
- Product
Sends a request to a remote endpoint without waiting for a response.
Sends a request to a remote endpoint without waiting for a response.
An optional request context is used to supply additional information needed to send the request.
Value parameters
- mediaType
-
message media (MIME) type.
- requestBody
-
request message body
- requestContext
-
request context
- requestId
-
request correlation identifier
Attributes
- Returns
-
nothing
- Definition Classes
- Inherited from:
- SttpClientBase (hidden)
Inherited fields
Attributes
- Inherited from:
- Logging (hidden)