Package graphql.kickstart.spring.webflux.apollo

Class ReactiveApolloSubscriptionSession

java.lang.Object
graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession
graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionSession
graphql.kickstart.spring.webflux.apollo.ReactiveApolloSubscriptionSession
All Implemented Interfaces:
graphql.kickstart.execution.subscriptions.SubscriptionSession
public class ReactiveApolloSubscriptionSession extends graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionSession

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveApolloSubscriptionSession(graphql.kickstart.execution.subscriptions.GraphQLSubscriptionMapper mapper, org.springframework.web.reactive.socket.WebSocketSession webSocketSession)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close(String reason)
     
    String
    getId()
     
    Map<String,Object>
    getUserProperties()
     
    boolean
    isOpen()
     
    org.springframework.web.reactive.socket.WebSocketSession
    unwrap()
     

    Methods inherited from class graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionSession

    sendCompleteMessage, sendDataMessage, sendErrorMessage

    Methods inherited from class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession

    add, getMapper, getPublisher, getSubscriptions, send, sendMessage, subscribe, toString, unsubscribe

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactiveApolloSubscriptionSession

      public ReactiveApolloSubscriptionSession(graphql.kickstart.execution.subscriptions.GraphQLSubscriptionMapper mapper, org.springframework.web.reactive.socket.WebSocketSession webSocketSession)

  • Method Details

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface graphql.kickstart.execution.subscriptions.SubscriptionSession
      Overrides:
      isOpen in class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession

    • close

      public void close(String reason)
      Specified by:
      close in interface graphql.kickstart.execution.subscriptions.SubscriptionSession
      Overrides:
      close in class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession

    • getUserProperties

      public Map<String,Object> getUserProperties()
      Specified by:
      getUserProperties in interface graphql.kickstart.execution.subscriptions.SubscriptionSession
      Overrides:
      getUserProperties in class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession

    • getId

      public String getId()
      Specified by:
      getId in interface graphql.kickstart.execution.subscriptions.SubscriptionSession
      Overrides:
      getId in class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession

    • unwrap

      public org.springframework.web.reactive.socket.WebSocketSession unwrap()
      Specified by:
      unwrap in interface graphql.kickstart.execution.subscriptions.SubscriptionSession
      Overrides:
      unwrap in class graphql.kickstart.execution.subscriptions.DefaultSubscriptionSession