Use an ImmediateExecutor for Promise#flat_map not to schedule unneeded tasks

obrok · obrok · commit 3cb66e04eb16 · 2014-10-05T22:36:27.000+02:00
diff --git a/lib/concurrent/promise.rb b/lib/concurrent/promise.rb
@@ -121,7 +121,7 @@ def rescue(&block)
     def flat_map(&block)
       child = Promise.new(
         parent: self,
-        executor: @executor,
+        executor: ImmediateExecutor.new,
       )
 
       on_error { |e| child.on_reject(e) }

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ def rescue(&block)`
`121`	`121`	`def flat_map(&block)`
`122`	`122`	`child = Promise.new(`
`123`	`123`	`parent: self,`
`124`		`- executor: @executor,`
	`124`	`+ executor: ImmediateExecutor.new,`
`125`	`125`	`)`
`126`	`126`
`127`	`127`	`on_error { \|e\| child.on_reject(e) }`