building_data_pipelines_1_1.clj

(ns pipeline.articles.one
  (:require [clojure.spec.alpha :as s]
            [clojure.core.async :as a]
            [clojure.string :as st]))

(defn capitalize-subscriber-name
  [{subscriber :data :as message}]
  (update subscriber 
          :name 
          st/upper-case))