Class WebSocketSubscription<T>

  • Type Parameters:
    T - type of a data item that should be returned by a WebSocket subscription.

    public class WebSocketSubscription<T>
    extends java.lang.Object
    Objects necessary to process a new item received via a WebSocket subscription.
    • Constructor Summary

      Constructors 
      Constructor Description
      WebSocketSubscription​(io.reactivex.subjects.BehaviorSubject<T> subject, java.lang.Class<T> responseType)
      Creates WebSocketSubscription.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.Class<T> getResponseType()  
      io.reactivex.subjects.BehaviorSubject<T> getSubject()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • WebSocketSubscription

        public WebSocketSubscription​(io.reactivex.subjects.BehaviorSubject<T> subject,
                                     java.lang.Class<T> responseType)
        Creates WebSocketSubscription.
        Parameters:
        subject - used to send new data items to listeners
        responseType - type of a data item returned by a WebSocket subscription
    • Method Detail

      • getSubject

        public io.reactivex.subjects.BehaviorSubject<T> getSubject()
      • getResponseType

        public java.lang.Class<T> getResponseType()