Home Reference Source
public class | source

NodePropagationProtocol

You can directly use an instance of this class. nodePropagationProtocol

Constructor Summary

Public Constructor
public

Member Summary

Private Members
private

_newFullNodesWaitList: {"length": *}

private

_newLightNodesWaitList: {"length": *}

private

Method Summary

Public Methods
public

count(socket: *): *

public
public
public
public
Private Methods
private

_getWaitlist(response: *, list: *): *

private

_newNodeConnected(nodeWaitListObject: *)

private

_nodeDisconnected(nodeWaitListObject: *)

private

async _processList(list: *, nodeType: *)

private
private

async _processNodesList(response: *, socket: *)

Public Constructors

public constructor() source

Private Members

private _newFullNodesWaitList: {"length": *} source

private _newLightNodesWaitList: {"length": *} source

private _waitlistProccessed: {} source

Public Methods

public count(socket: *): * source

Params:

NameTypeAttributeDescription
socket *

Return:

*

public initializeNodesPropagation(socket: *) source

Params:

NameTypeAttributeDescription
socket *

public initializeNodesSimpleWaitlist(socket: *) source

Params:

NameTypeAttributeDescription
socket *

public initializePropagationProtocol() source

public initializeSocketForPropagation(socket: *) source

Params:

NameTypeAttributeDescription
socket *

Private Methods

private _getWaitlist(response: *, list: *): * source

Params:

NameTypeAttributeDescription
response *
list *

Return:

*

private _newNodeConnected(nodeWaitListObject: *) source

Params:

NameTypeAttributeDescription
nodeWaitListObject *

private _nodeDisconnected(nodeWaitListObject: *) source

Params:

NameTypeAttributeDescription
nodeWaitListObject *

private async _processList(list: *, nodeType: *) source

Params:

NameTypeAttributeDescription
list *
nodeType *

private async _processNewWaitlistInterval() source

private async _processNodesList(response: *, socket: *) source

Params:

NameTypeAttributeDescription
response *
socket *