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 == '*'