Contents

require_relative "threaded"

module Plumbing
  module Actor
    class Rails < Threaded
      protected

      def future(&)
        Concurrent::Promises.future do
          Rails.application.executor.wrap(&)
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
standard-procedure-plumbing-0.4.2	lib/plumbing/actor/rails.rb
standard-procedure-plumbing-0.4.1	lib/plumbing/actor/rails.rb
standard-procedure-plumbing-0.4.0	lib/plumbing/actor/rails.rb