Adianto Wibisono wibisono

Balaji Sivaraman @balajisivaraman_twitter

Hi all, I need some help understanding a piece of Doobie code from the examples. It is the StreamingCopy one: (https://github.com/tpolecat/doobie/blob/series/0.4.x/yax/example/src/main/scala/example/StreamingCopy.scala). I am using a modified version of the fuseMap2 example from that file. Here’s how I’ve modified it for my requirements:

  def fuseMap[F[_]: Catchable: Monad, A, B](
      source: Process[ConnectionIO, A],
      sink: Vector[A] => ConnectionIO[B],
      delete: ConnectionIO[Unit]
  )(
 sourceXA: Transactor[F],

	package com.danielasfregola.tutorial.cat.applicative

	import com.danielasfregola.tutorial.cat.functor.Functor

	trait Applicative[Box[_]] extends Functor[Box] {

	def pure[A](a: A): Box[A]

	def ap[A, B](boxF: Box[A => B])(boxA: Box[A]): Box[B]