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)
}
}
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment