class Grumlin::Client::PoolResource
Attributes
client[R]
Public Class Methods
call()
click to toggle source
# File lib/grumlin/client.rb, line 8 def self.call config = Grumlin.config new(config.url, client_factory: config.client_factory, concurrency: config.client_concurrency) end
new(url, client_factory:, concurrency: 1, parent: Async::Task.current)
click to toggle source
Calls superclass method
# File lib/grumlin/client.rb, line 13 def initialize(url, client_factory:, concurrency: 1, parent: Async::Task.current) super(concurrency) @client = client_factory.call(url, parent).tap(&:connect) @parent = parent end
Public Instance Methods
close()
click to toggle source
# File lib/grumlin/client.rb, line 23 def close @client.close end
closed?()
click to toggle source
# File lib/grumlin/client.rb, line 19 def closed? !@client.connected? end
reusable?()
click to toggle source
# File lib/grumlin/client.rb, line 37 def reusable? !closed? end
viable?()
click to toggle source
# File lib/grumlin/client.rb, line 33 def viable? !closed? end
write(bytecode)
click to toggle source
# File lib/grumlin/client.rb, line 27 def write(bytecode) @client.write(bytecode) ensure @count += 1 end