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)
  if stream.name == "CatalogItems"
    klass.send(@action, item_attrs)
  else
    klass.send(@action)
  end
end