Class: Xeno::StreamsController::NdjsonWriter

Inherits:

Object

• Object
• Xeno::StreamsController::NdjsonWriter

Defined in:

app/controllers/xeno/streams_controller.rb

Overview

NDJSON framing: one envelope per line (type/index live inside the envelope); a bare newline as keepalive — line parsers skip empties.

Instance Method Summary

• #close ⇒ Object
• #content_type ⇒ Object
• #event(record) ⇒ Object
• #initialize(stream) ⇒ NdjsonWriter constructor

  A new instance of NdjsonWriter.

• #keepalive ⇒ Object

Constructor Details

#initialize(stream) ⇒ NdjsonWriter

Returns a new instance of NdjsonWriter.

# File 'app/controllers/xeno/streams_controller.rb', line 32

def initialize(stream)
  @stream = stream
end

Instance Method Details

#close ⇒ Object

# File 'app/controllers/xeno/streams_controller.rb', line 39

def close = @stream.close

#content_type ⇒ Object

# File 'app/controllers/xeno/streams_controller.rb', line 36

def content_type = "application/x-ndjson"

#event(record) ⇒ Object

# File 'app/controllers/xeno/streams_controller.rb', line 37

def event(record) = @stream.write("#{JSON.generate(record.envelope)}\n")

#keepalive ⇒ Object

# File 'app/controllers/xeno/streams_controller.rb', line 38

def keepalive = @stream.write("\n")