RxJava support

If you're using Apollo Kotlin in a Java project or Kotlin project that uses RxJava, you can use Apollo's RxJava extensions.

To do so, add the apollo-rx2-support-java / apollo-rx3-support-java (Java) or apollo-rx2-support / apollo-rx3-support (Kotlin) dependency to your project:

build.gradle[.kts]

1
dependencies {
2
  // ...
3

4
  // For RxJava 2
5
  implementation("com.apollographql.apollo3:apollo-rx2-support-java:4.0.0-alpha.3")
6

7
  // For RxJava 3
8
  implementation("com.apollographql.apollo3:apollo-rx3-support-java:4.0.0-alpha.3")
9
}

build.gradle[.kts]

1
dependencies {
2
  // ...
3

4
  // For RxJava 2
5
  implementation("com.apollographql.apollo3:apollo-rx2-support:4.0.0-alpha.3")
6

7
  // For RxJava 3
8
  implementation("com.apollographql.apollo3:apollo-rx3-support:4.0.0-alpha.3")
9
}

Executing operations

In Java, Use the Rx2Apollo or Rx3Apollo classes to execute GraphQL operations and get RxJava observables.

In Kotlin, use the rxSingle() / rxFlowable() extensions.

1
import com.apollographql.apollo3.rx3.java.Rx3Apollo;
2

3
// (...)
4

5
// Query
6
ApolloCall<MyQuery.Data> queryCall = client.query(new MyQuery());
7
Single<ApolloResponse<MyQuery.Data>> queryResponse = Rx3Apollo.single(queryCall);
8
queryResponse.subscribe( /* ... */ );
9

10
// Mutation
11
ApolloCall<MyMutation.Data> mutationCall = client.mutation(new MyMutation("my-parameter"));
12
Single<ApolloResponse<MyMutation.Data>> mutationResponse = Rx3Apollo.single(mutationCall);
13
mutationResponse.subscribe( /* ... */ );
14

15
// Subscription
16
ApolloCall<MySubscription.Data> subscriptionCall = client.subscription(new MySubscription());
17
Flowable<ApolloResponse<MySubscription.Data>> subscriptionResponse = Rx3Apollo.flowable(subscriptionCall);
18
subscriptionResponse.subscribe( /* ... */ );

1
// Query
2
client.query(MyQuery()).rxSingle().subscribe(/* ... */)
3

4
// Mutation
5
client.mutation(MyMutation("my-parameter")).rxSingle().subscribe(/* ... */)
6

7
// Subscription
8
client.subscription(MySubscription()).rxFlowable().subscribe(/* ... */)

Using with Java

Kotlin native