Class: Roda::RodaPlugins::Streaming::Stream::Scheduler

Inherits:
Object
  • Object
show all
Defined in:
lib/roda/plugins/streaming.rb

Overview

The default scheduler to used when streaming, useful for code using ruby’s default threading support.

Instance Method Summary collapse

Constructor Details

#initialize(stream) ⇒ Scheduler

Store the stream to schedule.



92
93
94
 
# File 'lib/roda/plugins/streaming.rb', line 92

def initialize(stream)
  @stream = stream
end

Instance Method Details

#defer ⇒ Object

Immediately yield.



97
98
99
 
# File 'lib/roda/plugins/streaming.rb', line 97

def defer(*)
  yield
end

#schedule ⇒ Object

Close the stream if there is an exception when scheduling, and reraise the exception if so.



103
104
105
106
107
108
 
# File 'lib/roda/plugins/streaming.rb', line 103

def schedule(*)
  yield
rescue Exception
  @stream.close
  raise
end