a responder for one connection
- Inheritance
- Object
- ConnectionHandler
- Responder
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