com.apollographql.apollo.internal.subscription

Interface SubscriptionManager

All Known Implementing Classes:

NoOpSubscriptionManager

public interface SubscriptionManager

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SubscriptionManager.Callback<T>

Method Summary

Modifier and Type	Method and Description
void	addListener(com.apollographql.apollo.api.Subscription subscription, AppSyncSubscriptionCall.Callback callback) Sets the listener based on the subscription's operation (unique) id
void	removeListener(com.apollographql.apollo.api.Subscription subscription, AppSyncSubscriptionCall.Callback callback) Removes the listener based on the subscription's operation (unique) id
void	setScalarTypeAdapters(ScalarTypeAdapters scalarTypeAdapters)
void	setStore(ApolloStore apolloStore) Sets the store used for cache updates based on subscription responses.
<T> void	subscribe(com.apollographql.apollo.api.Subscription<?,T,?> subscription, java.util.List<java.lang.String> subbedTopics, SubscriptionResponse response, ResponseNormalizer<java.util.Map<java.lang.String,java.lang.Object>> mapResponseNormalizer) Make a connection and subscribe to all topics.
void	unsubscribe(com.apollographql.apollo.api.Subscription<?,?,?> subscription)

Method Detail

subscribe

<T> void subscribe(@Nonnull
                   com.apollographql.apollo.api.Subscription<?,T,?> subscription,
                   @Nonnull
                   java.util.List<java.lang.String> subbedTopics,
                   @Nonnull
                   SubscriptionResponse response,
                   ResponseNormalizer<java.util.Map<java.lang.String,java.lang.Object>> mapResponseNormalizer)

Make a connection and subscribe to all topics.

Type Parameters:

T - The type of the repsonse data

Parameters:

subscription - The operation that has parsing logic, operation id, etc.

subbedTopics - The topics relevant to the subscription.

response - list of mqtt connections and topics

mapResponseNormalizer -

unsubscribe

void unsubscribe(@Nonnull
                 com.apollographql.apollo.api.Subscription<?,?,?> subscription)

addListener

void addListener(com.apollographql.apollo.api.Subscription subscription,
                 AppSyncSubscriptionCall.Callback callback)

Sets the listener based on the subscription's operation (unique) id

Parameters:

subscription - The subscription for which callbacks will be triggered.

callback - The callback for messages received on the subscription connection.

removeListener

void removeListener(com.apollographql.apollo.api.Subscription subscription,
                    AppSyncSubscriptionCall.Callback callback)

Removes the listener based on the subscription's operation (unique) id

Parameters:

subscription - The subscription for which callbacks will be triggered.

callback - The callback for messages received on the subscription connection.

setStore

void setStore(ApolloStore apolloStore)

Sets the store used for cache updates based on subscription responses.

Parameters:

apolloStore -

setScalarTypeAdapters

void setScalarTypeAdapters(ScalarTypeAdapters scalarTypeAdapters)