Package org.web3j.protocol.websocket

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()