Concurrent uploading in mirror services

perform_across_services is now called perform_async_across_services and accepts block which is runs async for given service

Author: SGospodinov

lib/active_storage/service/mirror_service.rb

@@ -18,24 +18,24 @@ def initialize(primary:, mirrors:)
   end
 
   def upload(key, io, checksum: nil)
-    each_service.collect do |service|
-      service.upload key, io.tap(&:rewind), checksum: checksum
+    perform_async_across_services do |service|
+      service.upload key, StringIO.new(io.tap(&:rewind).read), checksum: checksum
     end
   end
 
   def delete(key)
-    perform_across_services :delete, key
+    perform_async_across_services { |service| service.delete key }
   end
 
   private
     def each_service(&block)
       [ primary, *mirrors ].each(&block)
     end
 
-    def perform_across_services(method, *args)
-      promises = services.collect do |service|
-        Concurrent::Promise.execute { service.public_send method, *args }
+    def perform_async_across_services(&block)
+      promises = each_service.collect do |service|
+        Concurrent::Promise.execute { yield service }
       end
-      Concurrent::Promise.zip(*promises).value
+      Concurrent::Promise.zip(*promises).value!
     end
 end