Implement Future#cancel

celluloid · May 9, 2013 · b2703c7 · b2703c7
1 parent 09125dc
commit b2703c7
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/lib/celluloid/future.rb b/lib/celluloid/future.rb
@@ -84,6 +84,7 @@ def value(timeout = nil)
 
     # Signal this future with the given result value
     def signal(value)
+      return if @cancelled
       result = Result.new(value, self)
 
       @mutex.synchronize do
@@ -99,6 +100,14 @@ def signal(value)
     end
     alias_method :<<, :signal
 
+    def cancel(error)
+      response = ErrorResponse.new(@call, error)
+      signal response
+      @mutex.synchronize do
+        @cancelled = true
+      end
+    end
+
     # Inspect this Celluloid::Future
     alias_method :inspect, :to_s