org.polkadot.rpc.rx

Class RpcRx

java.lang.Object

org.polkadot.rpc.rx.Types.RpcRxInterface

org.polkadot.rpc.rx.RpcRx

public class RpcRx
extends Types.RpcRxInterface

RpcRx The RxJS API is a wrapper around the API. It allows wrapping API components with observables using RxJS.

Example

import org.polkadot.rpc.rx.RpcRx;
import org.polkadot.rpc.provider.wsWsProvider;
<p>
WsProvider provider = new WsProvider('http://127.0.0.1:9944');
RpcRx api = new RpcRx(provider);

Field Summary

Fields inherited from class org.polkadot.rpc.rx.Types.RpcRxInterface

author, chain, state, system

Constructor Summary

Constructors

Constructor and Description
RpcRx(IProvider provider)
RpcRx(RpcCore rpc)

Method Summary

Modifier and Type	Method and Description
protected void	emit(IProvider.ProviderInterfaceEmitted type, java.lang.Object... args)
<any>	isConnected()

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcRx

public RpcRx(IProvider provider)

Parameters:

provider - An API provider using HTTP or WebSocket

RpcRx

public RpcRx(RpcCore rpc)

Parameters:

rpc - An API provider using HTTP or WebSocket

Method Detail

isConnected

public <any> isConnected()

emit

protected void emit(IProvider.ProviderInterfaceEmitted type,
                    java.lang.Object... args)