Class: Roda::RodaPlugins::Streaming::Stream
- Inherits:
-
Object
- Object
- Roda::RodaPlugins::Streaming::Stream
- Includes:
- Enumerable
- Defined in:
- lib/roda/plugins/streaming.rb
Overview
Class of the response body in case you use #stream.
Three things really matter: The front and back block (back being the block generating content, front the one sending it to the client) and the scheduler, integrating with whatever concurrency feature the Rack handler is using.
Scheduler has to respond to defer and schedule.
Defined Under Namespace
Classes: Scheduler
Instance Method Summary collapse
-
#<<(data) ⇒ Object
Add output to the streaming response body.
-
#callback(&block) ⇒ Object
(also: #errback)
Add the given block as a callback to call when the block closes.
-
#close ⇒ Object
If not already closed, close the connection, and call any callbacks.
-
#closed? ⇒ Boolean
Whether the connection has already been closed.
-
#each(&front) ⇒ Object
Yield values to the block as they are passed in via #<<.
-
#initialize(opts = OPTS, &back) ⇒ Stream
constructor
Handle streaming options, see Streaming for details.
Constructor Details
#initialize(opts = OPTS, &back) ⇒ Stream
Handle streaming options, see Streaming for details.
90 91 92 93 94 95 96 97 98 99 100 |
# File 'lib/roda/plugins/streaming.rb', line 90 def initialize(opts=OPTS, &back) @scheduler = opts[:scheduler] || Scheduler.new(self) @back = back.to_proc @keep_open = opts[:keep_open] @callbacks = [] @closed = false if opts[:callback] callback(&opts[:callback]) end end |
Instance Method Details
#<<(data) ⇒ Object
Add output to the streaming response body.
103 104 105 106 |
# File 'lib/roda/plugins/streaming.rb', line 103 def <<(data) @scheduler.schedule{@front.call(data.to_s)} self end |
#callback(&block) ⇒ Object Also known as: errback
Add the given block as a callback to call when the block closes.
109 110 111 112 |
# File 'lib/roda/plugins/streaming.rb', line 109 def callback(&block) return yield if closed? @callbacks << block end |
#close ⇒ Object
If not already closed, close the connection, and call any callbacks.
119 120 121 122 123 |
# File 'lib/roda/plugins/streaming.rb', line 119 def close return if closed? @closed = true @scheduler.schedule{@callbacks.each(&:call)} end |
#closed? ⇒ Boolean
Whether the connection has already been closed.
126 127 128 |
# File 'lib/roda/plugins/streaming.rb', line 126 def closed? @closed end |
#each(&front) ⇒ Object
Yield values to the block as they are passed in via #<<.
131 132 133 134 135 136 137 138 139 140 141 |
# File 'lib/roda/plugins/streaming.rb', line 131 def each(&front) @front = front @scheduler.defer do begin @back.call(self) rescue Exception => e @scheduler.schedule{raise e} end close unless @keep_open end end |