Sha256: 746e3d7e8e74d1d59b3b5f11dbbebd9e36874c033a71103d009c9e122cc32130
Contents?: true
Size: 366 Bytes
Versions: 21
Compression:
Stored size: 366 Bytes
Contents
# frozen_string_literal: true
require_relative '../../polyphony'
require 'mysql2/client'
# Mysql2::Client overrides
Mysql2::Client.prepend(Module.new do
def initialize(config)
config[:async] = true
super
@io = ::IO.for_fd(socket)
end
def query(sql, **options)
super
Thread.current.backend.wait_io(@io, false)
async_result
end
end)
Version data entries
21 entries across 21 versions & 1 rubygems