Redis fixes

This commit is contained in:
Fosco Marotto
2021-01-16 14:38:01 -05:00
parent 8d48c3ce3d
commit 1214b0664c
3 changed files with 16 additions and 9 deletions

View File

@@ -101,7 +101,11 @@ class AccountConversation < ApplicationRecord
end
def subscribed_to_timeline?
Redis.current.exists?("subscribed:#{streaming_channel}")
exists = false
Redis.current.with do |conn|
exists = conn.exists?("subscribed:#{streaming_channel}")
end
exists
end
def streaming_channel