Sha256: d2b84bc7b2a6688740d881e87e178892c7aaa0f507b12e74f5c9faa507ad910c

Contents?: true

Size: 1.35 KB

Versions: 69

Compression:

Stored size: 1.35 KB

Contents

class Bundler::ConnectionPool
  class Wrapper < ::BasicObject
    METHODS = [:with, :pool_shutdown, :wrapped_pool]

    def initialize(options = {}, &block)
      @pool = options.fetch(:pool) { ::Bundler::ConnectionPool.new(options, &block) }
    end

    def wrapped_pool
      @pool
    end

    def with(&block)
      @pool.with(&block)
    end

    def pool_shutdown(&block)
      @pool.shutdown(&block)
    end

    def pool_size
      @pool.size
    end

    def pool_available
      @pool.available
    end

    def respond_to?(id, *args)
      METHODS.include?(id) || with { |c| c.respond_to?(id, *args) }
    end

    # rubocop:disable Style/MethodMissingSuper
    # rubocop:disable Style/MissingRespondToMissing
    if ::RUBY_VERSION >= "3.0.0"
      def method_missing(name, *args, **kwargs, &block)
        with do |connection|
          connection.send(name, *args, **kwargs, &block)
        end
      end
    elsif ::RUBY_VERSION >= "2.7.0"
      ruby2_keywords def method_missing(name, *args, &block)
        with do |connection|
          connection.send(name, *args, &block)
        end
      end
    else
      def method_missing(name, *args, &block)
        with do |connection|
          connection.send(name, *args, &block)
        end
      end
    end
    # rubocop:enable Style/MethodMissingSuper
    # rubocop:enable Style/MissingRespondToMissing
  end
end

Version data entries

69 entries across 69 versions & 4 rubygems

Version Path
bundler-2.3.20 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.19 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.19 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.18 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.18 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.17 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.17 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.16 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.16 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.15 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.15 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.14 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.14 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.13 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.13 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.12 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.12 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.11 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
bundler-2.3.11 lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb
rubygems-update-3.3.10 bundler/lib/bundler/vendor/connection_pool/lib/connection_pool/wrapper.rb