lib/attr/gather/aggregators/base.rb in attr-gather-1.1.3 vs lib/attr/gather/aggregators/base.rb in attr-gather-1.2.0

@@ -17,25 +17,23 @@
 
         def initialize(**opts)
           @filter = opts.delete(:filter) || NOOP_FILTER
         end
 
+        def with(**opts)
+          self.class.new(filter: @filter, **opts)
+        end
+
         def call(_original_input, _results_array)
           raise NotImplementedError
         end
 
         private
 
-        def wrap_result(result)
-          Concurrent::Promise.fulfill(result)
-        end
-
         def unwrap_result(res)
-          unvalidated = res.result.value!
+          return res if filter.nil?
 
-          return unvalidated if filter.nil?
-
-          filter.call(unvalidated).value
+          filter.call(res).value
         end
       end
     end
   end
 end