Sha256: da23954179e559b7702e3880c40f00624249d5b611a38eb352e2cb75199c4774
Contents?: true
Size: 873 Bytes
Versions: 7
Compression:
Stored size: 873 Bytes
Contents
#!/usr/bin/env ruby $:<< '../lib' << 'lib' # # A simple HTTP streaming API which returns a 202 (Accepted) response for any # GET request and then emits numbers 1 through 10 in 1 second intervals, and # then closes the connection. # # A good use case for this pattern would be to provide a stream of updates or a # 'firehose' like API to stream data back to the clients. Simply hook up to your # datasource and then stream the data to your clients via HTTP. # require 'goliath' class Stream < Goliath::API def on_close(env) env.logger.info "Connection closed." end def response(env) i = 0 pt = EM.add_periodic_timer(1) do env.stream_send("#{i}\n") i += 1 end EM.add_timer(10) do pt.cancel env.stream_send("!! BOOM !!\n") env.stream_close end streaming_response(202, {'X-Stream' => 'Goliath'}) end end
Version data entries
7 entries across 7 versions & 1 rubygems