Adding missing code

christospappas · Sep 29, 2012 · 23fb331 · 23fb331
1 parent ebb308f
commit 23fb331
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/streama/activity.rb b/lib/streama/activity.rb
@@ -57,13 +57,13 @@ def publish(verb, data)
 
       def stream_for(actor, options={})
         query = {:receivers => {'$elemMatch' => {:id => actor.id, :type => actor.class.to_s}}}
-        query.merge!({:verb => options[:type]}) if options[:type]
+        query.merge!({:verb.in => [*options[:type]]}) if options[:type]
         self.where(query).without(:receivers).desc(:created_at)
       end
 
       def stream_of(actor, options={})
          query = {'actor.id' => actor.id, 'actor.type' => actor.class.to_s}
-         query.merge!({:verb => options[:type]}) if options[:type]
+         query.merge!({:verb.in => [*options[:type]]}) if options[:type]
          self.where(query).without(:receivers).desc(:created_at)
       end