Class: ActionCable::Connection::MessageBuffer
- Inherits:
-
Object
- Object
- ActionCable::Connection::MessageBuffer
- Defined in:
- lib/action_cable/connection/message_buffer.rb
Overview
Allows us to buffer messages received from the WebSocket before the Connection has been fully initialized, and is ready to receive them.
Instance Method Summary collapse
- #append(message) ⇒ Object
-
#initialize(connection) ⇒ MessageBuffer
constructor
:nodoc:.
- #process! ⇒ Object
- #processing? ⇒ Boolean
Constructor Details
#initialize(connection) ⇒ MessageBuffer
:nodoc:
5 6 7 8 |
# File 'lib/action_cable/connection/message_buffer.rb', line 5 def initialize(connection) @connection = connection @buffered_messages = [] end |
Instance Method Details
#append(message) ⇒ Object
10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/action_cable/connection/message_buffer.rb', line 10 def append() if valid? if processing? receive else buffer end else connection.logger.error "Couldn't handle non-string message: #{.class}" end end |
#process! ⇒ Object
26 27 28 29 |
# File 'lib/action_cable/connection/message_buffer.rb', line 26 def process! @processing = true end |
#processing? ⇒ Boolean
22 23 24 |
# File 'lib/action_cable/connection/message_buffer.rb', line 22 def processing? @processing end |