a responder for one connection



Responder(NodeProvider nodeProvider, [ String reqId ])


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

openResponseCount → int

reqId → String

reqId can be a dsId or a user name

read / write
storage ISubscriptionResponderStorage

read / write
subscriptionCount → int

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


operator ==(other) → bool

The equality operator.



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

addToSendList(Map m) → void

clearProcessors() → void

getSendingData(int currentTime, int waitingAckId) ProcessorResult

gather all the changes from

noSuchMethod(Invocation invocation) → dynamic

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

toString() → String

Returns a string representation of this object.