PatrickJS · June 17, 2014 03:51 · Jun 17, 2014
diff --git a/limit.js b/limit.js
@@ -0,0 +1,25 @@
+//
+// Listen for messages and process all messages at steady rate limit.
+//
+pubnub.subscribe({
+    channel : "hello_world",
+    message : limit( function(message) { 
+
+        // process your messages at set interval here.
+
+    }, 500 /* milliseconds */ )
+});
+
+//
+// Rate Limit Function
+//
+function limit( fun, rate ) {
+    var queue = [];
+
+    setInterval( function() {
+        var msg = queue.shift();
+        msg && fun(msg);
+    }, rate );
+
+    return function(message) { queue.push(message) };
+}
diff --git a/thrimit.js b/thrimit.js
@@ -0,0 +1,30 @@
+//
+// Listen for events and process last message each 500ms.
+//
+pubnub.subscribe({
+    channel : "hello_world",
+    message : thrimit( function( last_message, all_messages ) { 
+
+        // process your last message here each 500ms.
+
+    }, 500 /* milliseconds */ )
+});
+
+//
+// Throttle + Limit Function
+//
+function thrimit( fun, rate ) {
+    var last;
+    var queue = [];
+
+    setInterval( function() {
+        last !== null && fun( last, queue );
+        last   = null;
+        queue  = []
+    }, rate );
+
+    return function(message) {
+        last = message;
+        queue.push(message);
+    };
+}
diff --git a/throttle.js b/throttle.js
@@ -0,0 +1,25 @@
+//
+// Listen for events and process last message each 500ms.
+//
+pubnub.subscribe({
+    channel : "hello_world",
+    message : throttle( function(message) { 
+
+        // process your last message here each 500ms.
+
+    }, 500 /* milliseconds */ )
+});
+
+//
+// Throttle Function
+//
+function throttle( fun, rate ) {
+    var last;
+
+    setInterval( function() {
+        last !== null && fun(last);
+        last = null;
+    }, rate );
+
+    return function(message) { last = message };
+}