aboutsummaryrefslogtreecommitdiffstats
path: root/actioncable/lib/action_cable
diff options
context:
space:
mode:
authorArun Agrawal <arunagw@gmail.com>2015-12-17 16:23:36 +0100
committerArun Agrawal <arunagw@gmail.com>2015-12-17 16:42:34 +0100
commite1459c7c86363d941191551505ad083d4335b815 (patch)
tree271617372f69e204a0c3c80467098809b8e57393 /actioncable/lib/action_cable
parent0957c8ad6722c1a82c16f70b23fe1f7cb2607ff5 (diff)
downloadrails-e1459c7c86363d941191551505ad083d4335b815.tar.gz
rails-e1459c7c86363d941191551505ad083d4335b815.tar.bz2
rails-e1459c7c86363d941191551505ad083d4335b815.zip
Remove warnings from actioncable
Warnings coming from code and test are removed
Diffstat (limited to 'actioncable/lib/action_cable')
-rw-r--r--actioncable/lib/action_cable/channel/base.rb3
-rw-r--r--actioncable/lib/action_cable/connection/base.rb4
-rw-r--r--actioncable/lib/action_cable/connection/message_buffer.rb3
-rw-r--r--actioncable/lib/action_cable/connection/subscriptions.rb3
-rw-r--r--actioncable/lib/action_cable/connection/web_socket.rb2
5 files changed, 11 insertions, 4 deletions
diff --git a/actioncable/lib/action_cable/channel/base.rb b/actioncable/lib/action_cable/channel/base.rb
index ca903a810d..f3085840ca 100644
--- a/actioncable/lib/action_cable/channel/base.rb
+++ b/actioncable/lib/action_cable/channel/base.rb
@@ -137,6 +137,9 @@ module ActionCable
# transmission until redis pubsub subscription is confirmed.
@defer_subscription_confirmation = false
+ @reject_subscription = nil
+ @subscription_confirmation_sent = nil
+
delegate_connection_identifiers
subscribe_to_channel
end
diff --git a/actioncable/lib/action_cable/connection/base.rb b/actioncable/lib/action_cable/connection/base.rb
index 7e9eec7508..f7b18a85ae 100644
--- a/actioncable/lib/action_cable/connection/base.rb
+++ b/actioncable/lib/action_cable/connection/base.rb
@@ -62,6 +62,7 @@ module ActionCable
@subscriptions = ActionCable::Connection::Subscriptions.new(self)
@message_buffer = ActionCable::Connection::MessageBuffer.new(self)
+ @_internal_redis_subscriptions = nil
@started_at = Time.now
end
@@ -138,10 +139,11 @@ module ActionCable
end
- private
+ protected
attr_reader :websocket
attr_reader :message_buffer
+ private
def on_open
connect if respond_to?(:connect)
subscribe_to_internal_channel
diff --git a/actioncable/lib/action_cable/connection/message_buffer.rb b/actioncable/lib/action_cable/connection/message_buffer.rb
index 25cff75b41..2f65a1e84a 100644
--- a/actioncable/lib/action_cable/connection/message_buffer.rb
+++ b/actioncable/lib/action_cable/connection/message_buffer.rb
@@ -29,10 +29,11 @@ module ActionCable
receive_buffered_messages
end
- private
+ protected
attr_reader :connection
attr_accessor :buffered_messages
+ private
def valid?(message)
message.is_a?(String)
end
diff --git a/actioncable/lib/action_cable/connection/subscriptions.rb b/actioncable/lib/action_cable/connection/subscriptions.rb
index 6199db4898..65d6634bb0 100644
--- a/actioncable/lib/action_cable/connection/subscriptions.rb
+++ b/actioncable/lib/action_cable/connection/subscriptions.rb
@@ -58,9 +58,10 @@ module ActionCable
subscriptions.each { |id, channel| channel.unsubscribe_from_channel }
end
+ protected
+ attr_reader :connection, :subscriptions
private
- attr_reader :connection, :subscriptions
delegate :logger, to: :connection
def find(data)
diff --git a/actioncable/lib/action_cable/connection/web_socket.rb b/actioncable/lib/action_cable/connection/web_socket.rb
index 169b683b8c..670d5690ae 100644
--- a/actioncable/lib/action_cable/connection/web_socket.rb
+++ b/actioncable/lib/action_cable/connection/web_socket.rb
@@ -22,7 +22,7 @@ module ActionCable
websocket.send data
end
- private
+ protected
attr_reader :websocket
end
end