lib/grumlin.rb in grumlin-0.3.0 vs lib/grumlin.rb in grumlin-0.4.0

@@ -10,10 +10,12 @@
 require "async/queue"
 require "async/barrier"
 require "async/http/endpoint"
 require "async/websocket/client"
 
+require_relative "async/channel"
+
 require_relative "grumlin/version"
 require_relative "grumlin/exceptions"
 
 require_relative "grumlin/transport"
 require_relative "grumlin/client"
@@ -36,15 +38,16 @@
 require_relative "grumlin/pop"
 require_relative "grumlin/sugar"
 
 module Grumlin
   class Config
-    attr_accessor :url, :pool_size, :client_concurrency
+    attr_accessor :url, :pool_size, :client_concurrency, :client_factory
 
-    # For some reason, client_concurrency must be greather pool_size
+    # For some reason, client_concurrency must be greater than pool_size
     def initialize
       @pool_size = 10
       @client_concurrency = 20
+      @client_factory = ->(url, parent) { Grumlin::Client.new(url, parent: parent) }
     end
 
     def default_pool
       @default_pool ||= Async::Pool::Controller.new(Grumlin::Client::PoolResource, limit: pool_size)
     end