class ListingProcessor[F[_]: Monad](transform: RawListing => FullListing,
save: Sink[F, Seq[FullListing]]) {
def process(listings: Seq[RawListing]): F[Unit] = {
val fullListings = listings.map(transform)
// ...logic, etc
save(fullListings)
}
}
Created
May 28, 2018 06:11
-
-
Save wjlow/808869f0476a82bbd70d7ab498db584d 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