suzanne.soy/travis-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

try simplifying pusher channel subscriptions

Browse Source
This commit is contained in:
Sven Fuchs 2013-09-06 14:03:25 +02:00
parent f827c155f5
commit aa286866a8
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
assets/scripts/app/pusher.coffee
View File

@ -19,25 +19,22 @@ $.extend Travis.Pusher.prototype,
@callbacksToProcess = [] @callbacksToProcess = []
Visibility.change (e, state) => Visibility.change (e, state) =>
if state == 'visible' @processSavedCallbacks() if state == 'visible'
@processSavedCallbacks()
setInterval @processSavedCallbacks.bind(this), @processingIntervalWhenHidden setInterval @processSavedCallbacks.bind(this), @processingIntervalWhenHidden
subscribeAll: (channels) -> subscribeAll: (channels) ->
for channel in channels @subscribe(channel) for channel in channels
name = @prefix(channel)
channel = @pusher.subscribe(channel)
channel.bind_all((event, data) => @receive(event, data))
subscribe: (channel) -> subscribe: (channel) ->
console.log("subscribing to #{channel}")
channel = @prefix(channel) channel = @prefix(channel)
@pusher.subscribe(channel).bind_all((event, data) => @receive(event, data)) unless @pusher?.channel(channel) console.log("subscribing to #{channel}")
unless @pusher?.channel(channel)
@pusher.subscribe(channel).bind_all((event, data) => @receive(event, data))
unsubscribe: (channel) -> unsubscribe: (channel) ->
console.log("unsubscribing from #{channel}")
channel = @prefix(channel) channel = @prefix(channel)
console.log("unsubscribing from #{channel}")
@pusher.unsubscribe(channel) if @pusher?.channel(channel) @pusher.unsubscribe(channel) if @pusher?.channel(channel)
prefix: (channel) -> prefix: (channel) ->