feat: Remove onPure

edahlseng · Jul 14, 2019 · c9b0c06 · c9b0c06
1 parent d946609
commit c9b0c06
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 16 deletions.
diff --git a/documentation/README.md b/documentation/README.md
@@ -192,7 +192,7 @@ interpreter :: (a -> Eff b c, effect -> boolean, effect -> (d -> void) -> void)
 ```flow
 type Interpreter<effect> = ({interpreterCotinuation: Interpreter<any>, interpreterRestart: Interpreter<any>}) => Eff<any, any> => void;
 
-declare function interpreter<a, b, c, d, effect>({ onPure: a => Eff<b, c>, predicate: (effect) => boolean, handler: (effect) => (d => void) => void}) => Interpreter effect
+declare function interpreter<a, b, c, d, effect>({ predicate: (effect) => boolean, handler: (effect) => (d => void) => void}) => Interpreter effect
 ```
 
 Example:
@@ -201,7 +201,6 @@ Example:
 import { interpreter, map, pure, send } from 'eff';
 
 const randomNumberInterpreter = interpreter({
-    onPure: pure,
     predicate: x => x.type === 'random-number',
     handler: effect => continuation => continuation(Math.random()),
 })
@@ -229,7 +228,6 @@ import { chain, interpreter, pure, run, send } from 'eff';
 const application = chain(value => pure(value * 2))(send({ type: 'random-number' }));
 
 const randomNumberInterpreter = interpreter({
-    onPure: pure,
     predicate: x => x.type === 'random-number',
     handler: effect => continuation => continuation(Math.random()),
 })

diff --git a/sources/eff.js b/sources/eff.js
@@ -91,11 +91,9 @@ export const run = (...interpreters: Array<Function>) => (
 export const send = (t: any) => Eff.Impure(t, Eff.Pure);
 
 export const interpreter = ({
-	onPure,
 	predicate,
 	handler,
 }: {
-	onPure: Function,
 	predicate: Function,
 	handler: Function,
 }) => ({
@@ -106,7 +104,7 @@ export const interpreter = ({
 	interpreterRestart: Function,
 }) => (m: EffMonad) =>
 	m.cata({
-		Pure: x => interpreterContinuation(onPure(x)),
+		Pure: x => interpreterContinuation(Eff.Pure(x)),
 		Impure: (effect, continuation) =>
 			predicate(effect)
 				? handler(effect)(

diff --git a/sources/fileSystem.js b/sources/fileSystem.js
@@ -4,7 +4,7 @@ import { taggedSum } from "daggy";
 import fs from "fs";
 import path from "path";
 
-import Eff, { interpreter, send } from "./eff";
+import { interpreter, send } from "./eff";
 
 const FileSystem = taggedSum("FileSystem", {
 	readFile: ["path"],
@@ -19,7 +19,6 @@ export const writeFile = (
 
 export const interpretLocalFileSystem = (fileSystemRoot: string) =>
 	interpreter({
-		onPure: x => Eff.Pure(x),
 		predicate: x => FileSystem.is(x),
 		handler: fileSystemEffect =>
 			fileSystemEffect.cata({

diff --git a/sources/input.js b/sources/input.js
@@ -20,7 +20,7 @@ import {
 	anyPass,
 } from "ramda";
 
-import Eff, { interpreter, send } from "./eff.js";
+import { interpreter, send } from "./eff.js";
 
 const Input = daggy.taggedSum("Input", {
 	getCharacter: [],
@@ -119,7 +119,6 @@ export const interpretInput = (
 	inputStream: stream$Readable & { +setRawMode?: boolean => void },
 ) =>
 	interpreter({
-		onPure: Eff.Pure,
 		predicate: x => Input.is(x),
 		handler: inputEffect =>
 			inputEffect.cata({

diff --git a/sources/output.js b/sources/output.js
@@ -2,7 +2,7 @@
 
 import daggy from "daggy";
 
-import Eff, { interpreter, send } from "./eff.js";
+import { interpreter, send } from "./eff.js";
 
 const Output = daggy.taggedSum("Output", {
 	putString: ["string"],
@@ -13,7 +13,6 @@ export const putStringLine = (s: string) => send(Output.putString(s + "\n"));
 
 export const interpretOutput = (outputStream: stream$Writable) =>
 	interpreter({
-		onPure: Eff.Pure,
 		predicate: x => Output.is(x),
 		handler: outputEffect =>
 			outputEffect.cata({

diff --git a/sources/reader.js b/sources/reader.js
@@ -2,7 +2,7 @@
 
 import daggy from "daggy";
 
-import Eff, { interpreter, send } from "./eff.js";
+import { interpreter, send } from "./eff.js";
 
 const Reader = daggy.taggedSum("Reader", {
 	get: [],
@@ -12,7 +12,6 @@ export const get = () => send(Reader.get);
 
 export const interpretReader = (i: any) =>
 	interpreter({
-		onPure: Eff.Pure,
 		predicate: x => Reader.is(x),
 		handler: readerEffect =>
 			readerEffect.cata({

diff --git a/sources/state.js b/sources/state.js
@@ -2,7 +2,7 @@
 
 import daggy from "daggy";
 
-import Eff, { interpreter, send } from "./eff.js";
+import { interpreter, send } from "./eff.js";
 
 const State = daggy.taggedSum("State", {
 	get: [],
@@ -19,7 +19,6 @@ export const interpretState = (startingState: mixed) => {
 	let state = startingState;
 
 	return interpreter({
-		onPure: Eff.Pure,
 		predicate: x => State.is(x),
 		handler: stateEffect =>
 			stateEffect.cata({