What is Effect?

7 minute read

In the world of Functional Programming, we are familiar with the Side-Effect¹, but we rarely mentioned Effect. In this blog, we will try to explain it from code.

What is Effect?

Extensible Effects: an alternative to Monad Transformers² give some definition of Effect

An effect is most easily understood as an interaction between a sub-expression and a central authority that administers the global resources of a program.

An effect can be viewed as a message to the central authority plus enough information to resume the suspended calculation.

It’s a little bit long and hard to understand for me, I would like to say An effect is just the return value of function

In the world of FP, function is the first class member and it should be pure. A function is assumed to interact with the outside world only by the input and return value, if it build connection with outside by other way, we say these ways are Side-Effect.

There are two type of interaction can be done between function and the outside of function.

Receive message from outside

A function usually uses input to receive message, but we also can implement it by return value(accually it return a new function to receive the message with input), see Reader monad.
Return message to outside A function without Side-Effect have to return message to outside by return value, the message returned by function is Effect.

Interpreter

All effects returned by function should have an interpreter which can be used to understand the effect by outside.

For example, when we invoke a function which return Option, we always need a pattern-match to interpret the Option

def div(v1:Double, v2:Double):Option[Double] = if(v2==0) None else Some(v1/v2)

def optionInterpreter(v:Option[Double]):String = v match {
  case Some(v1) => s"The result is ${v1}"
  case None => "The denominator can not be zero"
}

$ optionInterpreter(div(1,2))
The result is 0.5
$ optionInterpreter(div(1,0))
The denominator can not be zero

Let’s see another example about file operations, say we have an Effect to stand for different type of file operations

sealed trait FileOps[A]
case class ReadFile(path:String) extends FileOps[String]
case class SaveFile(path:String, content:String) extends FileOps[Boolean]

We also have some functions which return the FileOps effect

def getConfiguration:FileOps[String] = ReadFile("./config.xml")
def saveDataToCSV(name:String, content:String):FileOps[Boolean] = SaveFile(s"./tmp/${name}",content)

These functions are pure function, but pure function can’t help us to create/read a file, so we need an interpreter to do these things

def fileOpsInterpreter[A](v:FileOps[A]):A = v match {
  case ReadFile(path) => Source.fromFile(path).mkString
  case SaveFile(path, content) => try {
    val file = new File(path)
    val bw = new BufferedWriter(new FileWriter(file))
    bw.write(content)
    bw.close()
    true
  } catch {
    case e => false
  }
}

Then our final program will be

$ fileOpsInterpreter(getConfiguration)
pool_zide=1
port=8080

$ fileOpsInterpreter(saveDataToCSV("data1.csv","name,id\nJon,1001"))
true

How about save multiple csv files?

def saveCSVFiles(file1Content:String, file2Content:String, file3Content:String):Boolean = {
  if (fileOpsInterpreter(saveDataToCSV("data1.csv",file1Content)))
    if(fileOpsInterpreter(saveDataToCSV("data2.csv",file2Content)))
       fileOpsInterpreter(saveDataToCSV("data3.csv",file3Content))
    else
       false
  else 
    false
}

It looks ugly, could we reduce the boilerplate?

if (fileOpsInterpreter(saveDataToCSV(???,???)))
   fileOpsInterpreter(saveDataToCSV(???,???))
else
   false

Maybe we may add a flatMap like this

def flatMap[B](v:FileOps[A])(f:A=>FileOps[B]):FileOps[B] = v match {
  case ReadFile(path) => f(fileOpsInterpreter(v))
  case SaveFile(path, content) => {
    val isSuccess = fileOpsInterperter(v)
    if(isSuccess) f(result) else ???
  }
}

Then we can refine saveCSVFiles like this

def saveCSVFiles(file1Content:String, file2Content:String, file3Content:String):Boolean = {
  fileOpsInterpreter(
    flatMap(saveDataToCSV("data1.csv",file1Content))(
    _ => flatMap(saveDataToCSV("data2.csv",file2Content))(
      _ => saveDataToCSV("data3.csv",file3Content)
    )))
}

But we found the flatMap and fileOpsInterpreter are not pure and there is one place we are not sure how to implement in flatMap(we don’t know which effect should be returned when the SaveFile operation failed).

At this stage, we can say we can’t implement a pure flatMap for FileOps effect. Then what should we do? Can’t we use the effect whose interpreter looks like FileOps (it contains side-effect) ?

A special Effect

As we can see in the last section, we need to solve two problem to make the flatMap of FileOps pure and total.

Side-Effect introduced by fileOpsInterpreter
Definite effect returned by flatMap

Just like what we said in Review map and flatMap from code³ , we can create an new effect to remove the Side-Effect

sealed trait SpecialEffect[A]
case class FlatMap[A, B](v:FileOps[A], f:A=>FileOps[B]) extends SpecialEffect[B]

The flatMap of FileOps, interpreter of SpecialEffect can be implemented like this

def flatMap[B](v:FileOps[A])(f:A=>FileOps[B]):SpecialEffect[B] = FlatMap(v, f)
def specialInterpreter[A](v:SpecialEffect[A]):A = v match {
  case FlatMap(v1,f1) => fileOpsInterpreter(f1(fileOpsInterpreter(v1)))
}

The flatMap is pure. but it is not a correct flatMap now, because its return type is not FileOps. Seems it’s a conflict, we make it pure but we can’t make it follow the pattern of flatMap.

Let’s try a different way, if it is not possible to implement a flatMap for FileOps and we can use SpecialEffect to make the ideal flatMap pure, how about put the FileOps in SpecialEffect? then we can get a flatMap for SpecialEffect which contains all the information of FileOps. Let’s implement a function to do this

def lift[A](v:FileOps[A]):SpecialEffect[A] = FlatMap(v, ???)

Yeah, we don’t know how to implement the f of FlatMap, our idea is the f should be an identity function which won’t do anything for the v:FileOps, but there is no way to use FileOps to stand for identity.

So we have to refine the SpecialEffect like this

sealed trait SpecialEffect[A]
case class Pure[A](v:A) extends SpecialEffect[A]
case class FlatMap[A, B](v:FileOps[A], f: A=>SpecialEffect[B]) extends SpecialEffect[B]

Then the lift can be implemented like this

def lift[A](v:FileOps[A]):SpecialEffect[A] = FlatMap(v, x => Pure(x))

Cool, we wrapped the FileOps with SpecialEffect without changeing it, let’s see the flatMap and specialInterpreter now.

def flatMap[B](v:SpecialEffect[A])(f:A=>SpecialEffect[B]):SpecialEffect[B] = v match {
  case Pure(v1) => f(v1)
  case FlatMap(v1, f1) => FlatMap(v1, x => flatMap(f1(x))(f))
}

def specialInterpreter[A](v:SpecialEffect[A]):A = v match {
  case Pure(v1) => v1
  case FlatMap(v1,f1) => specialInterpreter(f1(fileOpsInterpreter(v1)))
}

Then the saveCSVFiles can be refined like this

def saveCSVFiles(file1Content:String, file2Content:String, file3Content:String):Boolean = {
  specialInterpreter(
    flatMap(lift(saveDataToCSV("data1.csv",file1Content)))(
    _ => flatMap(lift(saveDataToCSV("data2.csv",file2Content)))(
      _ => lift(saveDataToCSV("data3.csv",file3Content))
    )))
}

The only left thing is how to implement the if-else logic in SpecialEffect

if (fileOpsInterpreter(saveDataToCSV(???,???)))
   fileOpsInterpreter(saveDataToCSV(???,???))
else
   false

Is there any other effect has this similar feature which break the process if there are some errors? Yeah, we have Option, Either, IO, etc. Let’s try to refine the fileOpsInterpreter, specialInterpreter and saveCSVFiles

def fileOpsInterpreter[A](v:FileOps[A]):Option[A] = v match {
  case ReadFile(path) => Some(Source.fromFile(path).mkString)
  case SaveFile(path, content) => try {
    val file = new File(path)
    val bw = new BufferedWriter(new FileWriter(file))
    bw.write(content)
    bw.close()
    Some(true)
  } catch {
    case e => None
  }
} 

def specialInterpreter[A](v:SpecialEffect[A]):Option[A] = v match {
  case Pure(v1) => Some(v1)
  case FlatMap(v1,f1) => 
    fileOpsInterpreter(v1).flatMap(x=>interpreter(f1(x)))
}

def saveCSVFiles(file1Content:String, file2Content:String, file3Content:String):Boolean = {
  interpreter(
    flatMap(lift(saveDataToCSV("data1.csv",file1Content)))(
    _ => flatMap(lift(saveDataToCSV("data2.csv",file2Content)))(
      _ => lift(saveDataToCSV("data3.csv",file3Content))
    ))).fold(false,identity)
}

Awesome! the if-else logic is implemented in fileOpsInterpreter(v1).flatMap(it’s the flatMap of Option).

Everything looks good, we minimize the scope of Side-Effect code. now only fileOpsInterpreter has Side-Effect, other code can use pure way to work.

Actually we can control the program logic by using different return type of fileOpsInterpreter, for example, we can carry the error message by returning Either. the only restriction is the return type should be a Monad. Let’s make specialInterpreter more generic.

def specialInterpreter[A,M:Monad](v:SpecialEffect[A],f:FileOps~>M):M[A] = v match {
  case Pure(v1) => M.pure(v1)
  case FlatMap(v1,f1) => 
    f(v1).flatMap(x=>interpreter(f1(x)))
}

Maybe you already know the next step, we can also remove the FileOps to make SpecialEffect more generic to support any effect

sealed trait SpecialEffect[F[_], A]
case class Pure[F[_], A](v:A) extends SpecialEffect[F, A]
case class FlatMap[F[_], A, B](v:F[A], f: A=>SpecialEffect[F, B]) extends SpecialEffect[F, B]
def lift[F[_], A](v:F[A]):SpecialEffect[F, A] = FlatMap(v, x => Pure(x))
def specialInterpreter[A,M:Monad](v:SpecialEffect[A],f:F~>M):M[A] = v match {
  case Pure(v1) => M.pure(v1)
  case FlatMap(v1,f1) => 
    f(v1).flatMap(x=>interpreter(f1(x)))
}

With this SpecialEffect and a given mapping from effect to monad , all effect can do the functional programming without worrying about the Monad. Usually we call this SpecialEffect as FreeMonad.

Finally, I think the sentence in cats document is very useful for functional programmer.

The whole purpose of functional programming isn’t to prevent side-effects, it is just to push side-effects to the boundaries of your system in a well-known and controlled way. ⁴

The type of Effect

According to the previous section, we know there are at least two metrics can be used to evaluate effect.

Pure/Non-Pure - depend on if its interpreter is pure function
Total/Partial - depend on if it can describe all the logic in the map/flatMap.

For example, FileOps is a Partial effect, it can not describe the logic when SaveFile fail.

For Non-Pure or Partial effect, we have two ways to make it work in pure way

Don’t use this effect, implement it using function which return Pure and Total effect

For FileOps, we can create two function which return IO monad to stand for the file operations
```
def getConfiguration:IO[String] = IO(Source.fromFile(path).mkString)
def saveDataToCSV(name:String, content:String):IO[Unit] = 
 IO(
    val file = new File(path)
    val bw = new BufferedWriter(new FileWriter(file))
    bw.write(content)
    bw.close()
 )
```
The problem of this way are
- How to group these function in efficient way, Object or Class ?
- How to mock them in unit test, pass them as parameter?
Use Free Moand to help it.

The problem of this way are
- We need more code than the first option and it’s harder to understand.
- How to compose two effect?

References

Twitter Facebook LinkedIn

What is Effect?

What is Effect?

Interpreter

A special Effect

The type of Effect

References

Comments

You May Also Enjoy

How to use GPT-4 to do UI automation testing?

How to make a competent technical analysis?

How to make a team adopt Continuous Deployment?

shush: an alternative for Secrets Manager