()
| 4057 | var util = require("./util"); |
| 4058 | |
| 4059 | function Async() { |
| 4060 | this._customScheduler = false; |
| 4061 | this._isTickUsed = false; |
| 4062 | this._lateQueue = new Queue(16); |
| 4063 | this._normalQueue = new Queue(16); |
| 4064 | this._haveDrainedQueues = false; |
| 4065 | this._trampolineEnabled = true; |
| 4066 | var self = this; |
| 4067 | this.drainQueues = function () { |
| 4068 | self._drainQueues(); |
| 4069 | }; |
| 4070 | this._schedule = schedule; |
| 4071 | } |
| 4072 | |
| 4073 | Async.prototype.setScheduler = function(fn) { |
| 4074 | var prev = this._schedule; |
nothing calls this directly
no outgoing calls
no test coverage detected