add: async parameter

Author: pekopekopekopayo

lib/ld-eventsource/client.rb

@@ -52,6 +52,8 @@ class Client
     # The default HTTP method for requests.
     DEFAULT_HTTP_METHOD = "GET"
 
+    THREAD_NAME = 'LD/SSEClient'
+
     #
     # Creates a new SSE client.
     #
@@ -112,7 +114,8 @@ def initialize(uri,
           method: DEFAULT_HTTP_METHOD,
           payload: nil,
           retry_enabled: true,
-          http_client_options: nil)
+          http_client_options: nil,
+          async: true)
       @uri = URI(uri)
       @stopped = Concurrent::AtomicBoolean.new(false)
       @retry_enabled = retry_enabled
@@ -167,7 +170,11 @@ def initialize(uri,
 
       yield self if block_given?
 
-      Thread.new { run_stream }.name = 'LD/SSEClient'
+      if async
+        Thread.new { run_stream }.name = THREAD_NAME
+      else
+        run_stream
+      end
     end
 
     #