MCPcopy Index your code
hub / github.com/deployd/deployd / drainQueue

Function drainQueue

lib/session.js:143–150  ·  view source on GitHub ↗
(method, rawSocket, session)

Source from the content-addressed store, hash-verified

141 });
142
143 var drainQueue = function drainQueue(method, rawSocket, session) {
144 var key = '_' + method;
145 if (session.socket._bindQueue && session.socket._bindQueue[key] && session.socket._bindQueue[key].length) {
146 session.socket._bindQueue[key].forEach(function(args) {
147 rawSocket[method].apply(rawSocket, args);
148 });
149 }
150 };
151
152 // resolve queue once a socket is ready
153 socketQueue.on('socket', function(socket, session) {

Callers 1

SessionStoreFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected