spec/spec_helper.rb in twitter-stream-0.1.4 vs spec/spec_helper.rb in twitter-stream-0.1.6

@@ -10,6 +10,17 @@
   File.join(File.dirname(__FILE__), '..', 'fixtures', path)
 end
 
 def read_fixture(path)
   File.read(fixture_path(path))
+end
+
+def connect_stream(opts={}, &blk)
+  EM.run {
+    opts.merge!(:host => Host, :port => Port)
+    stop_in = opts.delete(:stop_in) || 0.5
+    EM.start_server Host, Port, JSONServer
+    @stream = JSONStream.connect(opts)
+    blk.call if blk
+    EM.add_timer(stop_in){ EM.stop }
+  }
 end
\ No newline at end of file