使用自定义 HTTP 客户端

1
class MyHttpEngine(val wrappedClient: MyClient) : HttpEngine {
2
  /**
3
   * Helper function to map the Apollo requests to MyClient requests
4
   */
5
  private fun HttpMethod.toMyClientRequest(): MyClientRequest {
6
    ...
7
  }
8

9
  /**
10
   * And the other way around
11
   */
12
  private fun MyClientResponse.toApolloResponse(): HttpResponse {
13
    ...
14
  }
15

16
  override suspend fun execute(request: HttpRequest) = suspendCancellableCoroutine { continuation ->
17

18
    val call = wrappedClient.newCall(request.toMyClientRequest())
19
    continuation.invokeOnCancellation {
20
      // If the coroutine is cancelled, also cancel the HTTP call
21
      call.cancel()
22
    }
23

24
    wrappedClient.enqueue(
25
        call,
26
        success = { myResponse ->
27
          // Success! report the response
28
          continuation.resume(myResponse.toApolloResponse())
29
        },
30
        error = { throwable ->
31
          // Error. Wrap in an ApolloException and report the error
32
          continuation.resumeWithException(ApolloNetworkException(throwable))
33
        }
34
    )
35
  }
36

37
  override fun dispose() {
38
    // Dispose any resources here
39
  }
40
}

1
// Use your HttpEngine
2
val client = ApolloClient.Builder()
3
  .serverUrl(serverUrl = "https://com.example/graphql")
4
  .httpEngine(httpEngine = MyHttpEngine(wrappedClient))
5
  .build()