Options
All
  • Public
  • Public/Protected
  • All
Menu

Class NewPendingTransactions

Description:

Subscribes to incoming pending transactions

Hierarchy

Index

Constructors

constructor

Properties

connection

connection: W3CWebsocket | WebSocket

emitter

emitter: mitt.Emitter

handlers

handlers: any

jsonRpc

jsonRpc: JsonRpc

messenger

messenger: Messenger

options

options: any

param

param: any

Protected reqMiddleware

reqMiddleware: ReqMiddleware = new Map().set('*', [])

Protected resMiddleware

resMiddleware: ResMiddleware = new Map().set('*', [])

shardID

shardID: number

subscriptionId

subscriptionId: any = null

subscriptions

subscriptions: any

url

url: string

Accessors

connected

  • get connected(): boolean

Methods

addEventListener

  • addEventListener(type: string, handler: mitt.Handler): void

clearSubscriptions

  • clearSubscriptions(unsubscribeMethod: string): Promise<boolean>

constructPayload

  • constructPayload(method: string, param: any, options?: any): RPCRequestPayload<any>

createWebsocketProvider

  • createWebsocketProvider(url: string, options?: any): w3cwebsocket | WebSocket

Protected getMiddleware

  • getMiddleware(method: RPCMethod | string): [ReqMiddleware[], ResMiddleware[]]

getSubscriptionEvent

  • getSubscriptionEvent(subscriptionId: any): any

hasSubscription

  • hasSubscription(subscriptionId: string): boolean

isConnecting

  • isConnecting(): boolean

on

  • on(type: string, handler: mitt.Handler): this

onClose

  • onClose(closeEvent: any): void

onConnect

  • onConnect(): Promise<void>

onData

  • onData(handler: any): this

onError

  • onError(event: any): void

onMessage

  • onMessage(msg: MessageEvent): void

onNewSubscriptionItem

  • onNewSubscriptionItem(subscriptionItem: any): any

onReady

  • onReady(event: any): void

once

  • once(type: string, handler: mitt.Handler): void

Protected pushMiddleware

  • pushMiddleware(fn: any, type: MiddlewareType, match: string | RPCMethod | RegExp): void

reconnect

  • reconnect(): void

registerEventListeners

  • registerEventListeners(): void

removeAllSocketListeners

  • removeAllSocketListeners(): void

removeEventListener

  • removeEventListener(type?: string, handler?: mitt.Handler): any

reset

  • reset(): void

resetHandlers

  • resetHandlers(): void

send

  • send(payload: RPCRequestPayload<object>): Promise<any>

start

  • start(): Promise<this>

subscribe

  • subscribe(payload: RPCRequestPayload<any[]>): Promise<any>

unsubscribe

  • unsubscribe(): Promise<any>

validate

  • validate(response: any, payload?: any): true | Error

Object literals

middlewares

middlewares: object

request

request: object

use

  • use(fn: ReqMiddleware, match?: string | RPCMethod | RegExp): void

response

response: object

use

  • use(fn: ResMiddleware, match?: string | RPCMethod | RegExp): void

Generated using TypeDoc