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