Contents

# frozen_string_literal: true

module Dry
  module Effects
    default = %i[
      cache current_time random resolve defer
      state interrupt cmp retry fork parallel
      async implicit env lock reader timestamp
      timeout
    ]

    effect_modules = ::Concurrent::Map.new

    default.each do |key|
      class_name = Inflector.camelize(key)

      if ::File.exist?("#{__dir__}/effects/#{key}.rb")
        effects.register(key, memoize: true) do
          require "dry/effects/effects/#{key}"
          Effects.const_get(Inflector.camelize(key))
        end

        singleton_class.class_eval do
          define_method(class_name) do |*args, **kwargs|
            effect_modules.fetch_or_store([key, args, kwargs]) do
              ::Dry::Effects.effects[key].new(*args, **kwargs).freeze
            end
          end
        end
      end

      if ::File.exist?("#{__dir__}/providers/#{key}.rb")
        providers.register(key, memoize: true) do
          require "dry/effects/providers/#{key}"
          Providers.const_get(Inflector.camelize(key))
        end

        Handler.singleton_class.define_method(class_name) do |*args, **kwargs|
          ::Dry::Effects.providers[key].mixin(*args, **kwargs)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
dry-effects-0.5.0	lib/dry/effects/all.rb