class Multiwoven::Integrations::Destination::Iterable::Client

def process_stream(record, stream)
  klass = ::Iterable.const_get(stream.name).new(*initialize_params(stream, record))
  item_attrs = initialize_attribute(stream, record)
  response = if stream.name == "CatalogItems"
               klass.send("create", item_attrs)
             else
               klass.send("create")
             end
  [item_attrs, response]
end