Method: TurbineRb::ProcessImpl#process

Defined in:
lib/turbine_rb.rb

#process(request, _call) ⇒ Object 



87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/turbine_rb.rb', line 87

def process(request, _call)
  records = TurbineRb::Records.new(request.records)

  # records are processed but not in proto format
  processed_records = @process.call(records: records)

  # to proto
  serialized_records = processed_records.map(&:serialize)

  Io::Meroxa::Funtime::ProcessRecordResponse.new(records: serialized_records)
end