Module: Facy::InputQueue
- Included in:
- Facy
- Defined in:
- lib/facy/input_queue.rb
Instance Method Summary collapse
- #_insert_item(item) ⇒ Object
- #insert_item(item) ⇒ Object
- #insert_lock ⇒ Object
- #item_print_queue ⇒ Object
- #mailbox_cache ⇒ Object
- #notification_print_queue ⇒ Object
- #printed_item ⇒ Object
- #stream_print_queue ⇒ Object
Instance Method Details
#_insert_item(item) ⇒ Object
33 34 35 |
# File 'lib/facy/input_queue.rb', line 33 def _insert_item(item) item_print_queue << item end |
#insert_item(item) ⇒ Object
27 28 29 30 31 |
# File 'lib/facy/input_queue.rb', line 27 def insert_item(item) insert_lock.synchronize do _insert_item(item) end end |
#insert_lock ⇒ Object
19 20 21 |
# File 'lib/facy/input_queue.rb', line 19 def insert_lock @insert_lock ||= Monitor.new end |
#item_print_queue ⇒ Object
15 16 17 |
# File 'lib/facy/input_queue.rb', line 15 def item_print_queue @item_print_queue ||= [] end |
#mailbox_cache ⇒ Object
23 24 25 |
# File 'lib/facy/input_queue.rb', line 23 def mailbox_cache @mailbox_cache ||= [] end |
#notification_print_queue ⇒ Object
11 12 13 |
# File 'lib/facy/input_queue.rb', line 11 def notification_print_queue @notification_print_queue ||= [] end |
#printed_item ⇒ Object
3 4 5 |
# File 'lib/facy/input_queue.rb', line 3 def printed_item @printed_item ||= Set.new end |
#stream_print_queue ⇒ Object
7 8 9 |
# File 'lib/facy/input_queue.rb', line 7 def stream_print_queue @stream_print_queue ||= [] end |