diff --git a/build/angular-faye.js b/build/angular-faye.js index 41de591..1e02f1f 100644 --- a/build/angular-faye.js +++ b/build/angular-faye.js @@ -22,6 +22,9 @@ }); }); }, + unsubscribe: function(channel) { + return this.client.unsubscribe(channel); + }, get: function(channel) { var deferred, sub; deferred = $q.defer(); diff --git a/build/angular-faye.min.js b/build/angular-faye.min.js index 55b43a1..e89c9a3 100644 --- a/build/angular-faye.min.js +++ b/build/angular-faye.min.js @@ -1,2 +1,2 @@ -/*! angular-faye 2014-10-03 */ -!function(){angular.module("faye",[]),angular.module("faye").factory("$faye",["$q","$rootScope",function(a,b){return function(c,d){var e,f;return f=b,e=new Faye.Client(c),"function"==typeof d&&d(e),{client:e,publish:function(a,b){return this.client.publish(a,b)},subscribe:function(a,b){return this.client.subscribe(a,function(a){return f.$apply(function(){return b(a)})})},get:function(b){var c,d;return c=a.defer(),d=this.client.subscribe(b,function(a){return f.$apply(function(){return c.resolve(a)}),d.cancel()}),c.promise}}}}])}.call(this); \ No newline at end of file +/*! angular-faye 2015-12-04 */ +(function(){angular.module("faye",[]),angular.module("faye").factory("$faye",["$q","$rootScope",function(a,b){return function(c,d){var e,f;return f=b,e=new Faye.Client(c),"function"==typeof d&&d(e),{client:e,publish:function(a,b){return this.client.publish(a,b)},subscribe:function(a,b){return this.client.subscribe(a,function(a){return f.$apply(function(){return b(a)})})},unsubscribe:function(a){return this.client.unsubscribe(a)},get:function(b){var c,d;return c=a.defer(),d=this.client.subscribe(b,function(a){return f.$apply(function(){return c.resolve(a)}),d.cancel()}),c.promise}}}}])}).call(this); \ No newline at end of file diff --git a/src/angular-faye.coffee b/src/angular-faye.coffee index 7db2810..23f16c8 100644 --- a/src/angular-faye.coffee +++ b/src/angular-faye.coffee @@ -16,6 +16,9 @@ angular.module("faye").factory "$faye", ["$q", "$rootScope", ($q, $rootScope) -> scope.$apply -> callback(data) + unsubscribe: (channel) -> + @client.unsubscribe channel + get: (channel) -> deferred = $q.defer() sub = @client.subscribe(channel, (data) ->