diff --git a/lib/faye_ttl.rb b/lib/faye_ttl.rb index eede05c67..2c876028a 100644 --- a/lib/faye_ttl.rb +++ b/lib/faye_ttl.rb @@ -31,6 +31,7 @@ def outgoing(message, callback) if subscription.start_with?(*channels) messages = history[subscription] unless messages.empty? + # TODO move this into the incoming message handler messages = messages.delete_if do |m| (Time.now.to_i - m['timestamp']) > ttl end