class ListingProcessor(transform: RawListing => FullListing,
save: String => Async[Unit]) {
def process(listings: Seq[RawListing]): Async[Unit] = {
val fullListings = listings.map(transform)
// ...logic, etc
save(fullListings.toJson)
}
}
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment