lib/ably/realtime/channel/publisher.rb in ably-1.2.2 vs lib/ably/realtime/channel/publisher.rb in ably-1.2.3
- old
+ new
@@ -3,10 +3,12 @@
# Publisher module adds publishing capabilities to the current object
module Publisher
private
# Prepare and queue messages on the connection queue immediately
+ #
# @return [Ably::Util::SafeDeferrable]
+ #
def enqueue_messages_on_connection(client, raw_messages, channel_name, channel_options = {})
messages = Array(raw_messages).map do |raw_msg|
create_message(client, raw_msg, channel_options).tap do |message|
next if message.client_id.nil?
if message.client_id == '*'