From fe144ebb3a79410f363844c4b5d104ec7b4d84e8 Mon Sep 17 00:00:00 2001 From: "Tj (bougyman) Vanderpoel" Date: Thu, 31 Jul 2025 13:40:25 -0500 Subject: [PATCH 1/2] fix: Run in blocking mode, not just non-blocking --- lib/leopard/nats_api_server.rb | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/leopard/nats_api_server.rb b/lib/leopard/nats_api_server.rb index f2d12cc..7b8740b 100644 --- a/lib/leopard/nats_api_server.rb +++ b/lib/leopard/nats_api_server.rb @@ -76,7 +76,8 @@ def use(klass, *args, &block) def run(nats_url:, service_opts:, instances: 1, blocking: true) logger.info 'Booting NATS API server...' # Return the thread pool if non-blocking - return spawn_instances(nats_url, service_opts, instances) unless blocking + pool = spawn_instances(nats_url, service_opts, instances) unless blocking + return pool unless blocking # Otherwise, just sleep the main thread forever sleep From 357eb9d19641cbcf2d17f152e8d2e0f3410d8428 Mon Sep 17 00:00:00 2001 From: "Tj (bougyman) Vanderpoel" Date: Thu, 31 Jul 2025 13:44:32 -0500 Subject: [PATCH 2/2] fix: Corrects the non-blocking mode for pool creation --- lib/leopard/nats_api_server.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/leopard/nats_api_server.rb b/lib/leopard/nats_api_server.rb index 7b8740b..0d74088 100644 --- a/lib/leopard/nats_api_server.rb +++ b/lib/leopard/nats_api_server.rb @@ -76,7 +76,7 @@ def use(klass, *args, &block) def run(nats_url:, service_opts:, instances: 1, blocking: true) logger.info 'Booting NATS API server...' # Return the thread pool if non-blocking - pool = spawn_instances(nats_url, service_opts, instances) unless blocking + pool = spawn_instances(nats_url, service_opts, instances) return pool unless blocking # Otherwise, just sleep the main thread forever