lib/sinatra-websocketio/websocketio.rb in sinatra-websocketio-0.2.1 vs lib/sinatra-websocketio/websocketio.rb in sinatra-websocketio-0.2.2

@@ -45,20 +45,21 @@
       end
     end
 
     def self.push(type, data, opt={})
       session_ids = opt[:to].to_s.empty? ? self.sessions.keys : [opt[:to]]
-      if opt.include? :to and self.sessions.include? opt[:to]
+      if opt.include? :to
+        return unless self.sessions.include? opt[:to]
         s = self.sessions[opt[:to]]
         begin
           s.send({:type => type, :data => data}.to_json)
         rescue => e
           emit :error, "websocketio push error (session:#{opt[:to]})"
         end
-      else
-        self.sessions.keys.each do |id|
-          push type, data, :to => id
-        end
+        return
+      end
+      self.sessions.keys.each do |id|
+        push type, data, :to => id
       end
     end
 
     def self.sessions
       @@sessions ||= Hash.new