The idea then being, let map() take each subscription and execute certain logic (cross joining to other records, updating fields, etc.)