2. 程式人生 > >深圳scala-meetup-20180902（2）- Future vs Task and ReaderMonad依賴注入

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

阿新 • • 發佈：2018-12-11
type FoodName = String type Quantity = Int type FoodStore = KVStore[String,Int] def addFood(food: FoodName, qty: Quantity)(implicit fs: FoodStore): Task[Quantity] = for { current <- fs.read(food) newQty = current.map(cq => cq + qty).getOrElse(qty) _ <- fs.update(food,newQty) }
yield newQty def takeFood(food: FoodName, qty: Quantity)(implicit fs: FoodStore): Task[Quantity] = for { current <- fs.read(food) cq = current.getOrElse(0) taken = Math.min(cq,qty) left = cq - taken _ <- if(left > 0) fs.update(food,left) else fs.delete(food) } yield taken def cookSauce(qty: Quantity)(
get: (FoodName,Quantity) => Task[Quantity], put: (FoodName,Quantity) => Task[Quantity]): Task[Quantity] = for { tomato <- get("Tomato",qty) vaggies <- get("Veggies",qty) _ <- get("Galic",10) sauceQ = tomato/2 + vaggies * 3 / 2 _ <- put("
Sauce",sauceQ) } yield sauceQ def cookPasta(qty: Quantity)(get: (FoodName,Quantity) => Task[Quantity], put: (FoodName,Quantity) => Task[Quantity]): Task[Quantity] = for { pasta <- get("Pasta", qty) sauce <- get("Sauce", qty) _ <- get("Spice", 3) portions = Math.min(pasta, sauce) _ <- put("Meal", portions) } yield portions

相關推薦

深圳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-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（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學習筆記（2）——一口氣講完用Itellij（Maven）建工程並打包的事情

在進行本地Scala環境配置時，需要完成以下幾個步驟： 1、安裝JDK，目前僅支援1.8版本； 2、安裝Scala，並配置對應的環境變數； 3、安裝Spark，並配置對應的環境變數； 4、安裝Intellij，並下載對應的scala plugin。 詳細可見： https:/

Scala學習筆記（2）—— Scala 函式

1 函式的定義 def 方法名(引數名：引數型別):返回值型別 = { // 方法體 //方法體內的最後一行是返回值，不需要 return } 當函式沒有輸入的引數，呼叫的時候可以不寫括號 package com.scalatest.scal

Android單元測試（6）：使用dagger2來做依賴注入

注： 1. 程式碼中的 //<= 表示新加的、修改的等需要重點關注的程式碼 2. Class#method表示一個類的instance method，比如 LoginPresenter#login 表示 LoginPresenter的login（非靜態）方法。 問題

Spring學習（三）IOC控制反轉與DI依賴注入

IOC（Inversion of Control，控制反轉）是spring的核心，貫穿始終。 所謂IOC，對於spring框架來說，就是由spring來負責控制物件的生命週期和物件間的關係： 傳統開發

Spring通過全類名（反射）配置Bean以及三種依賴注入

配置Bean其實就是使用DI依賴注入,將Bean交給IOC容器管理，實現IOC控制反轉，達到解耦的過程。 Spring通過全類名（反射）配置Bean特點： 1. 基於xml檔案的方式， 2. 通過全類名反射， 3. 依靠IOC容器， 4. 依賴注入的方式

大數據學習之Scala中main函數的分析以及基本規則（2）

語言 python rgs 數字 popu 結束 圖片 區別 返回 一、main函數的分析 首先來看我們在上一節最後看到的這個程序，我們先來簡單的分析一下。有助於後面的學習 object HelloScala { def main(args:

Scala 語言學習之語言基礎（2）

err 實參 col res pre tom mom argument final 註： --------scala 中的任何數據都是對象 --------Scala 可以對數據類型進行自動推導，所以定義變量時可省去數據類型==> 數據類型

【AWS系列】鐳速RaySync VS FTP （2）- AWS巴西聖保羅到阿裏雲深圳

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

Scala筆記整理（四）：Scala面向對象—類詳解2（繼承相關）

大數據 Scala [TOC] 單例 希望某個類只存在一個使用的對象，而不管有多少個調用者在使用它，就是單例的概念。 Java中的單例 package cn.xpleaf.single; /** * 單例模式-餓漢式（在屬性中先創建好對象，不管是否調用getInstance方法） * @auth

scala成長之路（2）對象和類

ascii int 紅色 部分 類名 基類 req 字面量 標識符 scala提供了一種特殊的定義單例的方法：object關鍵字 scala> object Shabi{ | val age = 0 | val name = "shabi"

scala筆記-條件控制與迴圈（2）

if表示式 ·if表示式的定義：在Scala中，if表示式是有值的，就是if或者else中最後一行語句返回的值。 ·例如，val age = 30; if (age > 18) 1 else 0 ·可以將if表示式賦予一個變數，例如，val isAdult = if (ag

Scala 專案開發實戰（2）

今天是學習王家林老師大資料的第二天，今天主要講的是Scala的基礎語法知識，下面開始Scala的開發之旅。 Tuple 使用 列印輸出 triple 中的內容 Arra

大資料學習-scala作業（2）

package com.jn.spark.lesson1 import scala.collection.mutable.ArrayBuffer /**  * 作業1：移除一個數組中第一個負數後的所有負數，（第一個負數要保留，其餘的負數都刪除）  * @author 江

scala 隨筆（2） scala建構函式 this

scala裡面的方法定義先於執行體載入，所以下面問題是沒有問題的 ，println(f) 先於定義 object Constructor { class Test{ println(f); def f = { "I am here!!!" }

大資料學習之Scala中main函式的分析以及基本規則（2）

一、main函式的分析 首先來看我們在上一節最後看到的這個程式，我們先來簡單的分析一下，有助於後面的學習 object HelloScala { def main(args: Array[String]): Unit = { printl

search（2）- elasticsearch scala終端：elastic4s

   上篇談到：elasticsearch本身是一個完整的後臺系統，對其的操作使用是通過終端api進行的。elasticsearch本身提供了多種程式語言的api，包括java的esjava。而elastic4s是一套基於esjava之上的scala api。 先看看scala 終端 El