Sha256: c939c7a04855c135053ad9353c8d47c4f5eb783e0ede526899f964ce906337ef

Contents?: true

Size: 1.94 KB

Versions: 105

Compression:

Stored size: 1.94 KB

Contents

function CircularBuffer(capacity) {
  var readPoint = 0;
  var writePoint = 0;
  var buffer = new Array(capacity);

  return {
    read: function () {
      if (isBufferEmpty()) { throw new BufferEmptyException(); }
      var data = buffer[readPoint];
      buffer[readPoint] = null;
      updateReadPoint();
      return data;
    },

    write: function (data) {
      updateBuffer(data, function () {
        if (isBufferFull()) { throw new BufferFullException(); }
        buffer[writePoint] = data;
      });
    },

    forceWrite: function (data) {
      updateBuffer(data, function () {
        if (isBufferFull()) { updateReadPoint(); }
        buffer[writePoint] = data;
      });
    },

    clear: function () {
      readPoint = 0;
      writePoint = 0;
      buffer = new Array(capacity);
    },

    isFull: function () {
      return isBufferFull();
    },

    isEmpty: function () {
      return isBufferEmpty();
    }
  };

  function isBufferEmpty() {
    return buffer.every(isEmpty);
  }

  function isBufferFull() {
    return buffer.filter(isFull).length === capacity;
  }

  function updateBuffer(data, callback) {
    if (isEmpty(data)) { return; }
    callback();
    updateWritePoint();
  }

  function updateWritePoint() {
    writePoint = (writePoint + 1) % capacity;
  }

  function updateReadPoint() {
    readPoint = (readPoint + 1) % capacity;
  }

  function isFull(data) {
    return !isEmpty(data);
  }

  function isEmpty(data) {
    return !data;
  }
}

function BufferEmptyException() {
  this.name = 'BufferEmptyException';
  this.message = 'Buffer is empty.';
}

function BufferFullException() {
  this.name = 'BufferFullException';
  this.message = 'Buffer is full.';
}

module.exports = {
  circularBuffer: function (capacity) {
    return new CircularBuffer(capacity);
  },

  bufferEmptyException: function () {
    return new BufferEmptyException();
  },

  bufferFullException: function () {
    return new BufferFullException();
  }
};

Version data entries

105 entries across 105 versions & 1 rubygems

Version Path
trackler-2.2.1.159 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.158 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.157 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.156 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.155 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.154 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.153 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.152 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.151 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.150 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.149 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.148 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.147 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.146 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.145 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.144 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.143 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.142 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.141 tracks/javascript/exercises/circular-buffer/example.js
trackler-2.2.1.140 tracks/javascript/exercises/circular-buffer/example.js