Join us from October 8-10 in New York City to learn the latest tips, trends, and news about GraphQL federation and API platform engineering.Join us for GraphQL Summit 2024 in NYC
Docs
Start for Free

Subscriptions in Apollo Kotlin


are long-lived read that can update their response over time, enabling clients to receive new data as it becomes available.

The GraphQL spec does not specify a particular protocol to use for operations. supports the following protocols:

  • WebSocket, using one of the following subprotocols:
    • subscriptions-transport-ws (⚠️ not actively maintained!)
    • graphql-ws
    • appsync (also uses graphql-ws as Sec-WebSocket-Protocol)

You must use whichever transport is supported by your GraphQL endpoint.

You define a subscription in your app just like you define a , except you use the subscription keyword. Here's an example subscription for getting the latest value of a number whenever that number is incremented:

subscription NumberIncremented {
numberIncremented
}

Unlike with queries and , a subscription can include only one of the Subscription type. To subscribe to multiple , you create multiple subscription operations.

Configuring WebSocket subscriptions

By default, Apollo Kotlin uses the subscriptions-transport-ws protocol for via the SubscriptionWsProtocol class. This protocol is no longer actively maintained. It remains the default for backward compatibility purposes.

A future version of Apollo Kotlin will change the default to the newer graphql-ws protocol and GraphQLWsProtocol class. If your server already uses graphql-ws, make sure to set your WsProtocol to GraphQLWsProtocol.

To use subscriptions over WebSocket, use WebSocketNetworkTransport:

val apolloClient = ApolloClient.Builder()
.subscriptionNetworkTransport(
WebSocketNetworkTransport.Builder()
.serverUrl("https://apollo-fullstack-tutorial.herokuapp.com/graphql")
.build()
)
.build()

Note: Apollo Kotlin supports both https:// (or http://) and wss:// (or ws://) protocols. Internally, wss:// is renamed to https:// and which one you use does not matter.

Customizing your WebSocket protocol

By default, Apollo Kotlin uses subscriptions-transport-ws for backward compatibility purposes, but it supports all of the following WebSocket subprotocols:

To customize your protocol, use the WsProtocol interface. Apollo Kotlin comes with built-in support for the subprotocols above:

SubprotocolClass
subscriptions-transport-wsSubscriptionWsProtocol (default)
graphql-wsGraphQLWsProtocol
appsyncAppSyncWsProtocol

For example, you can configure a graphql-ws transport like so:

val apolloClient = ApolloClient.Builder()
.subscriptionNetworkTransport(
WebSocketNetworkTransport.Builder()
.protocol(GraphQLWsProtocol.Factory())
.serverUrl("https://apollo-fullstack-tutorial.herokuapp.com/graphql")
.build()
)
.build()

Authentication

Please refer to this section about authentication with WebSocket.

Configuring HTTP subscriptions

To use HTTP for subscriptions, use HttpNetworkTransport like so:

val apolloClient = ApolloClient.Builder()
.subscriptionNetworkTransport(
HttpNetworkTransport.Builder()
.serverUrl("https://apollo-fullstack-tutorial.herokuapp.com/graphql")
.build()
)
.build()

This is the only configuration required. HttpNetworkTransport will use chunked multipart responses for subscription operations and standard POST or GET requests for queries and mutations.

Listening to a subscription

After you configure the NetworkTransport, use ApolloClient.subscribe to open the connection and listen for changes:

apolloClient.subscription(TripsBookedSubscription())
.toFlow()
.collect {
println("trips booked: ${it.data?.tripsBooked}")
}

Because subscriptions are long-lasting operations, they return a Flow<Response> instead of a single Response.

Terminating a subscription

Termination is handled through the coroutine scope. Cancel the coroutine to terminate the subscription.

By default, a single WebSocket is shared between all active subscriptions. When no subscription is active, the WebSocket is closed after a configurable timeout.

Error handling

Like queries, subscriptions support partial responses with GraphQL errors, which are emitted in the Flow.

Network errors terminate the Flow, and you need to retry to get new updates. Depending on the situation, retrying might open a new WebSocket or restart the subscription.

See also this section about WebSocket errors handling.

Previous
Mutations
Next
GraphQL variables
Rate articleRateEdit on GitHubEditForumsDiscord

© 2024 Apollo Graph Inc.

Privacy Policy

Company