module EM::Synchrony::ActiveRecord::Adapter

def set_current_transaction(t)
  if t == @closed_transaction
    @transaction.delete(Fiber.current.object_id)
  else
    @transaction[Fiber.current.object_id] = t
  end
end