class Nucleus::StreamCallback
Attributes
closed[RW]
Public Class Methods
new(stream)
click to toggle source
# File lib/nucleus/core/common/stream_callback.rb, line 7 def initialize(stream) @stream = stream @closed = false end
Public Instance Methods
close()
click to toggle source
Close the stream @return [void]
# File lib/nucleus/core/common/stream_callback.rb, line 21 def close log.debug 'Close API stream, invoked by adapter callback' # close API stream of the Rack server unless it was already closed @stream.close unless @closed end
send_message(message)
click to toggle source
Send a message via the stream to the client @param [String] message content to send to the client
# File lib/nucleus/core/common/stream_callback.rb, line 14 def send_message(message) log.debug "New streamed message part: #{message}" @stream.chunk message end