Package com.graphql_java_generator.client

Class SubscriptionClientReactiveImpl

java.lang.Object

com.graphql_java_generator.client.SubscriptionClientReactiveImpl

All Implemented Interfaces:

SubscriptionClient

public class SubscriptionClientReactiveImpl
extends java.lang.Object
implements SubscriptionClient

Default implementation for the SubscriptionClient interface.

Author:

etienne-sf

Constructor Summary

Constructors

Constructor	Description
SubscriptionClientReactiveImpl(java.lang.String uniqueIdOperation, com.graphql_java_generator.client.GraphQLReactiveWebSocketHandler.WebSocketSessionHandler webSocketSessionHandler)

Method Summary

Modifier and Type	Method	Description
org.springframework.web.reactive.socket.WebSocketSession	getSession()	Allow to retrieve the WebSocketSession, when the implementation is based on Spring Reactive, which is the default since release 1.12
void	unsubscribe()	Allows the client application to unsubscribe from a previously subscribed subscription.

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionClientReactiveImpl

public SubscriptionClientReactiveImpl(java.lang.String uniqueIdOperation,
                                      com.graphql_java_generator.client.GraphQLReactiveWebSocketHandler.WebSocketSessionHandler webSocketSessionHandler)

Parameters:

disposable - The Disposable That allows to close the underlying Flux, that receive the subscription notifications

webSocketSessionHandler - The connected WebSocketSession

Method Detail

unsubscribe

public void unsubscribe()
                 throws GraphQLRequestExecutionException

Description copied from interface: SubscriptionClient

Allows the client application to unsubscribe from a previously subscribed subscription. No more notification will be sent for this subscription.
This will free resources on both the client and the server.

Specified by:

unsubscribe in interface SubscriptionClient

Throws:

GraphQLRequestExecutionException

getSession

public org.springframework.web.reactive.socket.WebSocketSession getSession()

Description copied from interface: SubscriptionClient

Allow to retrieve the WebSocketSession, when the implementation is based on Spring Reactive, which is the default since release 1.12

Specified by:

getSession in interface SubscriptionClient

Returns:

The WebSocketSession, if the Spring reactive implementation is used. Or null otherwise