@@ -124,6 +124,13 @@ static void rb_curl_multi_run(VALUE self, CURLM *multi_handle, int *still_runnin multi_read_info( self, multi_handle ); } +static VALUE fire_and_forget(VALUE self) { + CurlMulti *curl_multi; + Data_Get_Struct(self, CurlMulti, curl_multi); + rb_curl_multi_run( self, curl_multi->multi, &(curl_multi->running) ); +// curl_multi_perform(curl_multi->multi, 0); +} + static VALUE multi_perform(VALUE self) { CURLMcode mcode; CurlMulti *curl_multi; @@ -215,4 +222,5 @@ void init_typhoeus_multi() { rb_define_private_method(klass, "multi_perform", multi_perform, 0); rb_define_private_method(klass, "multi_cleanup", multi_cleanup, 0); rb_define_private_method(klass, "active_handle_count", active_handle_count, 0); + rb_define_method(klass, "fire_and_forget", fire_and_forget, 0); } ext/typhoeus/typhoeus_multi.c @@ -20,6 +20,10 @@ module Typhoeus def clear_stubs @stubs = [] end + + def fire_and_forget + @multi.fire_and_forget + end def queue(request) return if assign_to_stub(request) lib/typhoeus/hydra.rb @@ -209,4 +209,16 @@ describe Typhoeus::Hydra do @responses.size.should == 3 (Time.now - start_time).should < 3.3 end + + it "should fire and forget" do + hydra = Typhoeus::Hydra.new + first = Typhoeus::Request.new("http://localhost:3000/first?delay=5") + second = Typhoeus::Request.new("http://localhost:3001/second?delay=10") + hydra.queue first + hydra.queue second + hydra.fire_and_forget + third = Typhoeus::Request.new("http://localhost:3002/third?delay=15") + hydra.queue third + hydra.fire_and_forget + end end spec/typhoeus/hydra_spec.rb d27380bbded11777c5884d23549d4fffc613fab1 Paul Dix paul@pauldix.net http://github.com/pauldix/typhoeus/commit/b900567d8258024f7be4a92e57978660c8199c96 b900567d8258024f7be4a92e57978660c8199c96 2009-10-16T14:26:51-07:00 2009-10-16T14:26:51-07:00 added ability to fire requests on multi without reading the return values 7e38e8541e2f58502f7e8b3098a8ba13747d1f1c Paul Dix paul@pauldix.net