Tweaks

Author: alistairjevans

ext/hyper_ruby/src/lib.rs

@@ -84,7 +84,8 @@ impl Server {
                  match work_request {
                     Ok(work_request) => {
                         // Call the Ruby block and handle the response
-                        let warp_response = match block.call::<_, Value>((work_request.request,)) {
+                        let req_ref = Obj::wrap(work_request.request);
+                        let warp_response = match block.call::<_, Value>([req_ref]) {
                             Ok(result) => {
                                 let ref_response = Obj::<Response>::try_convert(result).unwrap();
 
@@ -148,8 +149,6 @@ impl Server {
             .build()
             .map_err(|e| MagnusError::new(magnus::exception::runtime_error(), e.to_string()))?;
 
-        println!("Starting server");
-        
         rt.block_on(async {
             let work_tx = work_tx.clone();
 

ext/hyper_ruby/src/request.rs

@@ -4,7 +4,7 @@ use warp::http::HeaderMap;
 
 // Type passed to ruby giving access to the request properties.
 #[derive(Debug)]
-#[magnus::wrap(class = "HyperRuby::Request")]
+#[magnus::wrap(class = "HyperRuby::Request", free_immediately)]
 pub struct Request {
     pub method: warp::http::Method,
     pub path: String,

test/test_hyper_ruby.rb

@@ -35,6 +35,12 @@ def test_large_post
     end
   end
 
+  def test_blocking
+    with_server(-> (request) { handler_simple(request) }) do |client|
+      gets
+    end
+  end
+
   def with_server(request_handler, &block)
     server = HyperRuby::Server.new
     server.configure({ bind_address: "127.0.0.1:3010" })
@@ -60,7 +66,7 @@ def with_server(request_handler, &block)
   end
 
   def handler_simple(request)
-    HyperRuby::Response.new(200, { 'Content-Type' => 'text/plain' }, request.http_method)
+    HyperRuby::Response.new(200, { 'Content-Type' => 'text/plain' }, "ABC")
   end
 
   def handler_to_json(request)