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