com.apollographql.apollo.rx2

Class Rx2Apollo

java.lang.Object

com.apollographql.apollo.rx2.Rx2Apollo

public class Rx2Apollo
extends java.lang.Object

The Rx2Apollo class provides methods for converting ApolloCall, ApolloPrefetch and ApolloWatcher types to RxJava 2 sources.

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.Observable<com.apollographql.apollo.api.Response<T>>	from(com.apollographql.apollo.ApolloCall<T> call) Converts an ApolloCall to an Observable.
static io.reactivex.Completable	from(com.apollographql.apollo.ApolloPrefetch prefetch) Converts an ApolloPrefetch to a synchronous Completable
static <T> io.reactivex.Observable<com.apollographql.apollo.api.Response<T>>	from(com.apollographql.apollo.ApolloQueryWatcher<T> watcher) Converts an ApolloQueryWatcher to an asynchronous Observable.
static <T> io.reactivex.Flowable<com.apollographql.apollo.api.Response<T>>	from(com.apollographql.apollo.ApolloSubscriptionCall<T> call)
static <T> io.reactivex.Flowable<com.apollographql.apollo.api.Response<T>>	from(com.apollographql.apollo.ApolloSubscriptionCall<T> call, io.reactivex.BackpressureStrategy backpressureStrategy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

from

public static <T> io.reactivex.Observable<com.apollographql.apollo.api.Response<T>> from(@Nonnull
                                                                                         com.apollographql.apollo.ApolloQueryWatcher<T> watcher)

Converts an ApolloQueryWatcher to an asynchronous Observable.

Type Parameters:

T - the value type

Parameters:

watcher - the ApolloQueryWatcher to convert.

Returns:

the converted Observable

Throws:

java.lang.NullPointerException - if watcher == null

from

@Nonnull
public static <T> io.reactivex.Observable<com.apollographql.apollo.api.Response<T>> from(@Nonnull
                                                                                                  com.apollographql.apollo.ApolloCall<T> call)

Converts an ApolloCall to an Observable. The number of emissions this Observable will have is based on the ResponseFetcher used with the call.

Type Parameters:

T - the value type.

Parameters:

call - the ApolloCall to convert

Returns:

the converted Observable

Throws:

java.lang.NullPointerException - if originalCall == null

from

@Nonnull
public static io.reactivex.Completable from(@Nonnull
                                                     com.apollographql.apollo.ApolloPrefetch prefetch)

Converts an ApolloPrefetch to a synchronous Completable

Parameters:

prefetch - the ApolloPrefetch to convert

Returns:

the converted Completable

Throws:

java.lang.NullPointerException - if prefetch == null

from

@Nonnull
public static <T> io.reactivex.Flowable<com.apollographql.apollo.api.Response<T>> from(@Nonnull
                                                                                                com.apollographql.apollo.ApolloSubscriptionCall<T> call)

from

@Nonnull
public static <T> io.reactivex.Flowable<com.apollographql.apollo.api.Response<T>> from(@Nonnull
                                                                                                com.apollographql.apollo.ApolloSubscriptionCall<T> call,
                                                                                                @Nonnull
                                                                                                io.reactivex.BackpressureStrategy backpressureStrategy)