scala - TMap 在 ZIO RC18-2 上无法正常工作
问题描述
我尝试使用TMap
以下方式:
定义TMap
:
val chatIdMapSTM: ChatIds = TMap.make(camunda_group -> camundaChatId, "pme123" -> 275469757L)
输入一个条目:
def registerChat(maybeId: Option[ChatUserOrGroup], chatId: ChatId): ZIO[Any, RegisterException, String] =
(for {
chatStm <- chatIdMapSTM
_ <- maybeId.map(id => chatStm.put(id, chatId)).getOrElse(chatIdMapSTM)
values <- chatStm.values // List(1212, 275469757, -319641852)
} yield chatStm).commit
.as("your chat was successful registered")
然后尝试获取该值:
def requestChat(chatUserOrGroup: ChatUserOrGroup): UIO[ChatId] =
(for {
chatStm <- chatIdMapSTM
values <- chatStm.values // List(275469757, -319641852)
chatId <- chatStm.getOrElse(chatUserOrGroup, camundaChatId)
} yield chatId).commit
正如评论所暗示的,当我请求条目时,新值不存在。
我错过了什么吗?
解决方案
似乎你从来没有提交过聊天地图,因此你总是“从头开始”。请参阅以下工作示例:
import zio._
import zio.console._
import zio.stm._
object ChatsExample extends App {
def run(args: List[String]) =
for {
map <- chatIdMapSTM.commit
res <- registerChat(map, "dejan", 123L)
_ <- putStrLn(res)
chat <- requestChat(map, "dejan")
_ <- putStrLn(s"Found id: $chat")
vals <- map.values.commit
_ <- putStrLn(vals.mkString(","))
} yield 0
val camundaChatId = 0L
val chatIdMapSTM = TMap.make("camunda" -> camundaChatId, "pme123" -> 275469757L)
def registerChat(chats: TMap[String, Long], userId: String, chatId: Long) =
(chats.put(userId, chatId).as("your chat was successfully registered")).commit
def requestChat(chats: TMap[String, Long], userId: String) =
chats.getOrElse(userId, camundaChatId).commit
}
推荐阅读
- acumatica - 在本地 ACUMATICA 中生成多个文本文件
- node.js - webpack用css/scss文件生成js文件
- php - 有条件或精确位数的正则表达式
- c - 如何在 C 编程中正确终止字符串?
- python - 为什么匹配的正则表达式模式结果中出现“\n”字符?
- python - 在 jupyter ModuleNotFoundError 上导入 sknw
- c++ - 使用一些 3d 元素创建 gui
- php - 我的 php 文件需要超过五分钟才能开始运行
- php - 为什么 Composer 没有根据我的 composer.json 文件中的要求更新我的 /vendor 文件夹?
- tensorflow - 如何在损失函数中使用 tf.contrib.image.rotate?