Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
def queryProgram(xa: Transactor[IO]) =
sql"""SELECT your_fields FROM your_table"""
.query[YourModel]
.stream
.transact(xa)
.evalMap(d => IO(println(d)))
.compile
.drain
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment