Contents

module ActiveGraph
  module Transaction
    def failure
      super
      @failure = true
    end

    def close
      success
      super
    end

    def after_commit(&block)
      after_commit_registry << block
    end

    def apply_callbacks
      after_commit_registry.each(&:call) unless @failure
    end

    private

    def after_commit_registry
      @after_commit_registry ||= []
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
activegraph-10.2.0.beta.1	lib/active_graph/transaction.rb
activegraph-10.1.1	lib/active_graph/transaction.rb
activegraph-10.1.0	lib/active_graph/transaction.rb
activegraph-10.0.2	lib/active_graph/transaction.rb