2. 程式人生 > >深圳scala-meetup-20180902（3）- Using heterogeneous Monads in for-comprehension with Monad Transformer

深圳scala-meetup-20180902（3）- Using heterogeneous Monads in for-comprehension with Monad Transformer

阿新 • • 發佈：2018-12-12
object session41 extends App { type DBOError[A] = EitherT[Task,String,A] type DBOResult[A] = OptionT[DBOError,A] def valueToDBOResult[A](a: A) : DBOResult[A] = Applicative[DBOResult].pure(a) def optionToDBOResult[A](o: Option[A]): DBOResult[A] = OptionT(o.pure[DBOError]) def eitherToDBOResult[A](e: Either[String,A]): DBOResult[A]
= { val error: DBOError[A] = EitherT.fromEither[Task](e) OptionT.liftF(error) } def taskToDBOResult[A](task: Task[A]): DBOResult[A] = { val error: DBOError[A] = EitherT.liftF[Task,String,A](task) OptionT.liftF(error) } def task[T](t: T): Task[T] = Task.delay(t) def add(a: Int, b: Int): Task[Int]
= Task.delay(a + b) val calc: DBOResult[Int] = for { a <- valueToDBOResult(10) b <- optionToDBOResult(Some(3)) //None: Option[Int]) c <- eitherToDBOResult(Left[String,Int]("oh my good ...")) d <- taskToDBOResult(add(b,c)) } yield d val sum: Task[Either[String,Option[Int]]]
= calc.value.value import monix.execution.Scheduler.Implicits.global import scala.util._ sum.runOnComplete { case Success(s) => println(s"DBOResult sum=$s") case Failure(exception) => println(exception.getMessage) } } //DBOResult sum=Left(oh my good ...)

相關推薦

深圳scala-meetup-20180902（3）- Using heterogeneous Monads in for-comprehension with Monad Transformer

object session41 extends App { type DBOError[A] = EitherT[Task,String,A] type DBOResult[A] = OptionT[DBOError,A] def valueToDBOResult[A](a: A) : DBO

深圳scala-meetup-20180902（1）- Monadic 程式設計風格

type FoodName = String type Quantity = Int type FoodStore = KVStore[String,Int] def addFood(food: FoodName, qty: Quantity )(implicit fs: FoodStore)

深圳scala-meetup-20180902（2）- Future vs Task and ReaderMonad依賴注入

type FoodName = String type Quantity = Int type FoodStore = KVStore[String,Int] def addFood(food: FoodName, qty: Quantity)(implicit fs: FoodStore)

深圳scala-meetup-20180902（2）- Future vs Task and ReaderMonad依賴注入

  在對上一次3月份的scala-meetup裡我曾分享了關於Future在函式組合中的問題及如何用Monix.Task來替代。具體分析可以查閱這篇博文。在上篇示範裡我們使用了Future來實現某種non-blocking資料庫操作，現在可以用Task替換Future部分： cla

Scala學習筆記（3）—— Scala面向物件

1 面向物件特點 封裝：屬性、方法封裝到類中； 繼承 多型：父類引用指向子類物件，開發框架的基石 package com.scalatest.scala.oop object SimpleObjectApp { def main(args: A

深度學習論文翻譯解析（三）：Detecting Text in Natural Image with Connectionist Text Proposal Network

論文標題：Detecting Text in Natural Image with Connectionist Text Proposal Network 論文作者：Zhi Tian , Weilin Huang, Tong He , Pan He , and Yu Qiao 論文原始碼的下載地址：htt

Scala 學習之面向對象（3）

繼承 abstract 接口 var lar 創建 int 一個 per ==> 類 ---> 類的定義class Student{ // 定義屬性 private var stuName:String = "Tom&qu

【AWS系列】鐳速RaySync VS FTP （3）- AWS倫敦到阿裏雲深圳

傳輸 測試 鐳速 測試軟件信息 鐳速RaySync下載地址: Windows Server: https://www.raysync.cn/support_for_windows.html Linux Server: https://www.raysync.cn/support_for_linux

scala筆記-函式入門（3）

函式的定義與呼叫 在Scala中定義函式時，需要定義函式的函式名、引數、函式體。 我們的第一個函式如下所示： def sayHello(name: String, age: Int) = { if (age > 18) { printf("hi %s, you are

scala學習（3）--map

scala在語法上和java千差萬別，他的函式很多，但是他卻完美的相容java的語法和物件，今天我們就說一下他是如何相容java的map的。 java的map Map<String,String> map = new HashedMap

【原創】案例分享（3）使用者行為分析--見證scala的強大

場景分析 使用者行為分析應用的場景很多，像線上網站訪問統計，線下客流分析（比如影象人臉識別、wifi探針等），比較核心的指標有幾個： PV | UV | SD | SC 指標說明： PV（Page View）：網站瀏覽量或者商場門店的訪問量UV（Unique Visitor）：獨立訪客數，即

探索Scala（3）-- 單例物件

研究一下Scala語言的單例物件（Singleton Objects），為下一篇文章做準備。 static不是關鍵字 上一篇文章提到過，interface並不是Scala語言關鍵字，可以自由使用。同樣，static在Scala裡也沒有特殊的含義，也是可以自由使用的，如下面程

Scala 基礎（3）—— 基礎型別和基礎操作

1. Scala 的一些基礎型別 Scala 提供了 8 種基礎型別，對應 Java 的 8 種基本資料型別。 其中包括： 整數型別：Byte, Short, Int, Long, Char 浮點型別：Float, Double 布林型別：Boolean 與 Java 不同，這 8 種資

Spark學習（3）——scala基礎語法

scala概述 scala是一門多正規化程式語言，集成了面向物件程式設計和函數語言程式設計等多種特性。 scala執行在虛擬機器上，併兼容現有的Java程式。      Scala原始碼被編譯成java位元組碼，所以執行在JVM上，並可以呼叫現有的Java類庫 scala

scala總結（3）-- scala中常用型別繼承關係

上圖： in Scala Nothing will be used for all null like use cases Option: either Some or None 典型應用： Map中get方法返回Option： scores.get(“Alice

restapi（3）- MongoDBEngine : MongoDB Scala程式設計工具庫

最近剛好有同事在學習MongoDB，我們討論過MongoDB應該置於伺服器端然後通過web-service為客戶端提供資料的上傳下載服務。我們可以用上節討論的respapi框架來實現針對MongoDB的CRUD操作。在談到restapi之前我在這篇討論先介紹一下MongoDB資料庫操作的scala程式設計，因

直播疑難雜癥排查（3）— 首開慢

播放器 問題 直播 排查 首開 本文是 《直播疑難雜癥排查》系列的第三篇文章，我們來看看直播過程中，最重要的一個性能指標：首開。1. 首開慢的表現點擊播放後，需要好幾秒才能顯示播放畫面。2. 常見首開慢問題排查2.1 點擊播放後才從服務器取播放地址播放視頻，第一件事就是要拿到播放地址，大多

Django 應用開發（3）

images alt doc include 新的 logs end esp eat 1.編寫第一個視圖 打開polls/view.py 利用一個URLconf將這個視圖映射到URL上。 首先先創建一個urls.py文件 編寫polls/urls.py 編寫m

(三)XML基礎（3）

ack cdata mage void 元素節點 images 包含 exce -1 五、XPath：快速定位到節點 　　5.1　　簡介 　　5.2　　語法 　　5.3　　案例 XPath對有命名空間的xml文件和沒有命名空間的xml定位節點的方法是

Scala學習筆記（一）編程基礎

大數據 上一個 extends 移除 condition api arr 調用方法 tab 強烈推薦參考該課程：http://www.runoob.com/scala/scala-tutorial.html 1. Scala概述 1.1. 什麽是Scala Scala