test subs warnings

src/pubsub/subscribe.jl

@@ -59,12 +59,7 @@ function _start_tasks(f::Function, async_handlers::Bool, subject::String, channe
                     async_handlers || wait(handler_task)
                 end
             catch err
-                if err isa InvalidStateException
-                    # This is fine, subscription is unsubscribed.
-                    @debug "Task for subscription on $subject finished."
-                else
-                    @error "Unexpected subscription error." err
-                end
+                err isa InvalidStateException || rethrow()
             end
         end)
     else
@@ -85,12 +80,7 @@ function _start_tasks(f::Function, async_handlers::Bool, subject::String, channe
                     Threads.atomic_sub!(handlers_running, 1)
                 end
             catch err
-                if err isa InvalidStateException
-                    # This is fine, subscription is unsubscribed.
-                    @debug "Task for subscription on $subject finished."
-                else
-                    @error "Unexpected subscription error." err
-                end
+                err isa InvalidStateException || rethrow()
             end
         end)
     end

test/connection.jl

@@ -138,4 +138,27 @@ end
     nonce = "HiA_hND1AV-DjmM"
     sig = "g4HDazX_ZZig_FOFBzhorLSYCEDRlv20Y5vErFjDlTRZMqaaF27ImP16es_GI83Fn59xr9V98Ux5GlEvvaeADQ"
     @test NATS.sign(nonce, seed) == sig
+end
+
+
+@testset "Subscription warnings" begin
+    nc = NATS.connect()
+
+    subscribe("too_many_handlers", async_handlers = true) do msg
+        sleep(21)
+    end
+
+    for _ in 1:1001
+        publish("too_many_handlers")
+    end
+
+    subscribe("overload_channel", async_handlers = false, channel_size = 100) do msg
+        sleep(21)
+    end
+
+    for _ in 1:81
+        publish("too_many_handlers")
+    end
+
+    sleep(21)
 end