This method isn't used anymore
parent
96ef933820
commit
dc5704b0b0
|
@ -37,11 +37,6 @@ class FeedManager
|
||||||
PushUpdateWorker.perform_async(timeline_type, account.id, status.id)
|
PushUpdateWorker.perform_async(timeline_type, account.id, status.id)
|
||||||
end
|
end
|
||||||
|
|
||||||
def broadcast(timeline_id, options = {})
|
|
||||||
options[:queued_at] = (Time.now.to_f * 1000.0).to_i
|
|
||||||
ActionCable.server.broadcast("timeline:#{timeline_id}", options)
|
|
||||||
end
|
|
||||||
|
|
||||||
def trim(type, account_id)
|
def trim(type, account_id)
|
||||||
return unless redis.zcard(key(type, account_id)) > FeedManager::MAX_ITEMS
|
return unless redis.zcard(key(type, account_id)) > FeedManager::MAX_ITEMS
|
||||||
last = redis.zrevrange(key(type, account_id), FeedManager::MAX_ITEMS - 1, FeedManager::MAX_ITEMS - 1)
|
last = redis.zrevrange(key(type, account_id), FeedManager::MAX_ITEMS - 1, FeedManager::MAX_ITEMS - 1)
|
||||||
|
|
Reference in New Issue