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