Sha256: 2ba89283c526dd5c9fedb513fc4f725d8dd3f0896566d10dcb2412ea4b4d232d
Contents?: true
Size: 764 Bytes
Versions: 28
Compression:
Stored size: 764 Bytes
Contents
class TestTrack::ThreadedVisitorNotifier
attr_reader :visitor
def initialize(visitor)
@visitor = visitor
end
def notify
payload = {
visitor_id: visitor.id,
assignments: visitor.unsynced_assignments
}
ActiveSupport::Notifications.instrument('test_track.notify_unsynced_assignments', payload) do
new_thread_with_request_store do
TestTrack::UnsyncedAssignmentsNotifier.new(payload).notify
end
end
end
private
def new_thread_with_request_store
Thread.new(RequestStore.store) do |original_store|
begin
RequestStore.begin!
RequestStore.store.merge!(original_store)
yield
ensure
RequestStore.end!
RequestStore.clear!
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems