a responder for one connection

Inheritance

Constructors

Responder(NodeProvider nodeProvider, [ String reqId ])

Properties

disabled → bool

read / write
groups → List<String>

list of permission group

read / write
maxCacheLength → int

read / write
maxPermission → int

max permisison of the remote requester, this requester won't be able to do anything with higher permission even when other permission setting allows it to. This feature allows reverse proxy to override the permission for each connection with url parameter

read / write
nodeProvider NodeProvider

caching of nodes

final
openResponseCount → int

read-only
reqId → String

reqId can be a dsId or a user name

read / write
storage ISubscriptionResponderStorage

read / write
subscriptionCount → int

read-only
connection ConnectionChannel

read / write, inherited
hashCode → int

The hash code for this object.

read-only, inherited
runtimeType → Type

A representation of the runtime type of the object.

read-only, inherited

Operators

operator ==(other) → bool

The equality operator.

inherited

Methods

addResponse(Response response, [ Path path = null, Object parameters = null ]) Response

addTraceCallback(ResponseTraceCallback _traceCallback) → void

close(Map m) → void

closeResponse(int rid, { Response response, DSError error }) → void

close the response from responder side and notify requester

initStorage(ISubscriptionResponderStorage s, List<ISubscriptionNodeStorage> nodes) → void

invoke(Map m) → void

list(Map m) → void

onData(List list) → void

onDisconnected() → void

onReconnected() → void

remove(Map m) → void

removeTraceCallback(ResponseTraceCallback _traceCallback) → void

set(Map m) → void

subscribe(Map m) → void

traceResponseRemoved(Response response) → void

unsubscribe(Map m) → void

updateGroups(List<String> vals, [ bool ignoreId = false ]) → void

updateInvoke(Map m) → void

updateResponse(Response response, List updates, { String streamStatus, List columns, Map meta, void handleMap(Map m) }) → void

addProcessor(ConnectionProcessor processor) → void

a processor function that's called just before the data is sent same processor won't be added to the list twice inside processor, send() data that only need to appear once per data frame

inherited
addToSendList(Map m) → void

inherited
clearProcessors() → void

inherited
getSendingData(int currentTime, int waitingAckId) ProcessorResult

gather all the changes from

inherited
noSuchMethod(Invocation invocation) → dynamic

Invoked when a non-existent method or property is accessed.

inherited
toString() → String

Returns a string representation of this object.

inherited