Method: MessageChannel::Observer#listen_once

Defined in:
lib/message_channel/observer.rb

#listen_once(*patterns) ⇒ Object 



44
45
46
47
48
49
50
 
# File 'lib/message_channel/observer.rb', line 44

def listen_once( *patterns )
  queue  =  Queue.new
  @awaits[queue]  =  patterns
  topic, items  =  * queue.pop
  @awaits.delete( queue )    rescue nil
  [topic, items]
end