Class: Gameworks::Servlet::AddObserver::DeferrableBody

Inherits:
Object
  • Object
show all
Includes:
EventMachine::Deferrable
Defined in:
lib/gameworks/servlet/add_observer.rb

Instance Method Summary collapse

Constructor Details

#initialize(wrapper) ⇒ DeferrableBody

Returns a new instance of DeferrableBody.



11
12
13
 
# File 'lib/gameworks/servlet/add_observer.rb', line 11

def initialize(wrapper)
  @wrapper = wrapper || "%s"
end

Instance Method Details

#call(json_chunk) ⇒ Object 



15
16
17
18
 
# File 'lib/gameworks/servlet/add_observer.rb', line 15

def call(json_chunk)
  document = json_chunk.gsub("\n", ' ') + "\n"
  @body_callback.call(@wrapper % [document])
end

#each(&blk) ⇒ Object 



20
21
22
 
# File 'lib/gameworks/servlet/add_observer.rb', line 20

def each(&blk)
  @body_callback = blk
end