fix: add explicit deinit to clean up nicely

Author: flexlixrup

Sources/Pulsar/PulsarClient/PulsarClient.swift

@@ -27,6 +27,12 @@ public final actor PulsarClient {
 	// Callback function called whenever the client gets closed, forcefully or user intended.
 	public let onClosed: ((Error) throws -> Void)?
 
+	deinit {
+		Task { [weak self] in
+			try await self?.close()
+		}
+	}
+
 	/// Creates a new Pulsar Client and tries to connect it.
 	/// - Parameters:
 	///   - host: The host to connect to. Doesn't need the `pulsar://` prefix.

Sources/PulsarExample/PulsarExample.swift

@@ -33,9 +33,15 @@ struct PulsarExample {
 	func connect(eventLoopGroup: EventLoopGroup) async throws {
 		var msgCount = 0
 
-		let client = await PulsarClient(host: "localhost", port: 6650, reconnectLimit: 1) { error in
-			print("Client closed")
-			throw error
+		let client = await PulsarClient(host: "localhost", port: 6650, reconnectLimit: 2) { error in
+			do {
+				throw error
+			} catch {
+				print("Client closed")
+				exit(0)
+			}
+
+			// throw error
 		}
 		let consumer = try await client.consumer(topic: "persistent://public/default/my-topic2", subscription: "test", subscriptionType: .shared, schema: .string) as PulsarConsumer<String>
 		Task {