org.web3j.protocol.websocket

Class WebSocketSubscription<T>

java.lang.Object

org.web3j.protocol.websocket.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 and Description
WebSocketSubscription(io.reactivex.subjects.BehaviorSubject<T> subject, java.lang.Class<T> responseType) Creates WebSocketSubscription.

Method Summary

Modifier and Type	Method and 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()