Added serialized/deserialized

Author: jacereda

src/Data/ArrayBuffer/Deserializer.purs

@@ -65,3 +65,18 @@ getFloat64Array d n = getTypedArray d (n * 8) TA.asFloat64Array
 deserializer :: forall e. AB.ArrayBuffer -> Eff (reader :: DV.Reader | e) Deserializer
 deserializer ab = return $ { dv : DV.whole ab, off : 0 }
 
+
+deserialized :: forall a e. (Deserializer -> Eff (reader :: DV.Reader | e) (Either String a)) -> AB.ArrayBuffer -> Either String a
+deserialized f b = runRPure (do
+          d <- deserializer b
+          res <- f d
+          return res)
+
+type WPure a = forall e. Eff (writer :: DV.Writer |e) a
+
+foreign import runRPure
+"""
+function runRPure(f) {
+  return f();
+}
+""" :: forall e a. Eff (|e) a -> a

src/Data/ArrayBuffer/Serializer.purs

@@ -30,8 +30,15 @@ serializer l = return $ { dv : DV.whole $ AB.create l, off : 0 }
 close :: Serializer -> forall e. Eff (writer :: DV.Writer | e) AB.ArrayBuffer
 close s = return $ AB.slice 0 s.off (DV.buffer s.dv)
 
-serialized :: forall e. ByteLength -> (Serializer -> Eff (writer :: DV.Writer | e) Unit) -> Eff (writer :: DV.Writer | e) AB.ArrayBuffer
-serialized n f = do
+serialized :: forall e. ByteLength -> (Serializer -> Eff (writer :: DV.Writer | e) Unit) -> AB.ArrayBuffer
+serialized n f = runWPure (do
   s <- serializer n
   f s
-  close s
+  close s)
+
+foreign import runWPure
+"""
+function runWPure(f) {
+  return f();
+}
+""" :: forall a e. Eff (| e) a -> a