diff --git a/rpc/ruby-server/rpc-helper.rb b/rpc/ruby-server/rpc-helper.rb index 2926310..34c4125 100644 --- a/rpc/ruby-server/rpc-helper.rb +++ b/rpc/ruby-server/rpc-helper.rb @@ -75,7 +75,7 @@ def self.serve(opts = {}, &compute) main_channel.reject(delivery_info.delivery_tag, true) end end - + ensure private_channel.close if use_thread_pool && private_channel end end