KCLManager.prototype._onShutdownRequested = function()

in lib/kcl/kcl_manager.js [197:216]

• 14 lines of code
• 2 McCabe index (conditional complexity)

KCLManager.prototype._onShutdownRequested = function(action) {
  var context = this._context;
  var recordProcessor = context.recordProcessor;
  var recordProcessorFunc = recordProcessor.shutdownRequested;

  if (typeof recordProcessorFunc === 'function') {
    var recordProcessorFuncInput = cloneToInput(action);
    var checkpointer = context.checkpointer;

    var callbackFunc = function() {
      this._recordProcessorCallback(context, action);
    }.bind(this);

    recordProcessorFuncInput.checkpointer = checkpointer;
    recordProcessorFunc.apply(recordProcessor, [recordProcessorFuncInput, callbackFunc]);
  }
  else {
    this._recordProcessorCallback(context, action);
  }
};