class ListingProcessor(transform: RawListing => FullListing,
save: Sink[Seq[FullListing]]) {
def process(listings: Seq[RawListing]): Async[Unit] = {
val fullListings = listings.map(transform)
// ...logic, etc
save(fullListings)
}
}
Created
May 28, 2018 06:06
-
-
Save wjlow/8187479f448a88069def7d5291658a8b to your computer and use it in GitHub Desktop.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment