Class: A2A::Server::BroadcastRegistry

Inherits:
Object
  • Object
show all
Defined in:
lib/simple_a2a/server/broadcast_registry.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ BroadcastRegistry

Returns a new instance of BroadcastRegistry.



6
7
8
9
 
# File 'lib/simple_a2a/server/broadcast_registry.rb', line 6

def initialize
  @broadcasts = {}
  @mutex      = Mutex.new
end

Instance Method Details

#find(task_id) ⇒ Object 



19
20
21
 
# File 'lib/simple_a2a/server/broadcast_registry.rb', line 19

def find(task_id)
  @mutex.synchronize { @broadcasts[task_id] }
end

#register(task_id, broadcast) ⇒ Object 



11
12
13
 
# File 'lib/simple_a2a/server/broadcast_registry.rb', line 11

def register(task_id, broadcast)
  @mutex.synchronize { @broadcasts[task_id] = broadcast }
end

#unregister(task_id) ⇒ Object 



15
16
17
 
# File 'lib/simple_a2a/server/broadcast_registry.rb', line 15

def unregister(task_id)
  @mutex.synchronize { @broadcasts.delete(task_id) }
end