방금 Akka/Scala를 배우기 시작했고 작은 대화방을 작성했습니다. 이것은 방 기반의 채팅 서버라고 상상해보십시오. 모두가 자신의 회의실을 만들 수 있으며 동시에 여러 회의실에있을 수 있습니다. 방에 부재원이 없을 때마다 방이 닫힙니다. 방은 id: Int으로 식별되며 변경 불가능한 name: String이 있습니다. 방을 제시하기 위해 다음 코드를
나는이 블로그 post을 읽고 있는데, Futures은 단지 부작용의 래퍼이므로 계산법이므로 "기능적"이라고 주장하지 않습니다. 예를 들어 RPC 호출, HTTP 요청 등을 포함합니다. 맞습니까? def twoUsersFeed(a: UserHandle, b: UserHandle)
(implicit ec: ExecutionContext): Fu
Java 8 CompletableFuture thenCompose 메소드의 이상한 동작이 발생했습니다. 실행 순서 만 다른 두 가지 테스트가 있습니다. 두 테스트 모두 thenCompose에서 생성 된 CompletableFuture의 실패를 시뮬레이트합니다. @Test
public void completedAfter() {
Completable
스칼라 (최신 버전), Reactivemongo (최신 버전) 및 Play 프레임 워크 (2.3.x)의 새로운 기능입니다. 세션을 확인하고 성공하면 사용자 객체를로드하여 JSON으로 반환합니다. 문제는 매핑과 미래에 국한된 문제입니다. 다음 코드는 컴파일되지 않습니다 : def userCheck(token: String) = Action.async {
scala의 Dispatch 라이브러리를 사용하여 API에서 데이터를 가져옵니다. 주에서는 장치의 ID에 연결된 센서 목록을 반환하는 getSensorList() 함수가 있습니다. 파견 Dispatch library 가 어떻게 주에 다시 미래를 반환 할 요청을 할 선물을 사용? 나는 내가 무엇을 구현하기 위해이 게시물을 따랐다 : 당신의 도움에 대한 Acc
저는 스칼라의 Future와 Akka에 대해 매우 새롭습니다. 현재 독립적 인 작업 목록을 실행하고 함께 결과를 수집하는 애플리케이션을 구현하려고합니다. 예를 들어, 여러 개의 작업으로 구성된 응용 프로그램을 만들고 싶습니다. 각 응용 프로그램은 숫자를 받고 몇 초 동안 잠자기 후 "Hello"메시지를 반환합니다. 주요 객체로 구현됩니다 class Hell
Grid Gain 6.5.5를 그리드상에서 계산 작업 배포를위한 잠재적 솔루션으로 평가하고 있습니다. 현재 우리가 직면하고있는 문제는 작업 완료 (또는 향후 완료)시 보낸 사람에게 비동기 적으로 알리는 적절한 비동기 알림 메커니즘이 없다는 것입니다. 프로토 타입 아키텍처는 비교적 간단하며 핵심 문제는 아래의 의사 코드에 나와 있습니다 (NDA로 인해 전체
/** When this future is completed, either through an exception, or a value,
* apply the provided function.
*
* If the future has already been completed,
* this will either be appli
파일 업로드를 허용하고 압축을 풀고 업로드 된 파일을 삭제하는 작은 서비스를 만들려고합니다. 이 세 단계는 미래로 묶여 있어야합니다. Google 구아바 라이브러리를 사용하고 있습니다. 워크 플로우는 다음 작업이 후, 파일을 압축 해제 할 수있는 미래를 완료하면 미래는, 파일을 다운로드 할 수 있습니다. 압축이 풀린 경우, 원래의 업로드 된 파일을 삭제할
나는 디스패치 라이브러리를 사용하는 HTTP 요청에 대해이 간단한 예제를 따르고있다. Dispatch tutorial 나는 선물을 사용하지 않고 요청을 만들고 싶어. 나는 응답을 기다리고 싶다. 어떻게해야합니까? 나는 미래의 선언과 oncomplete을 삭제하여 아래에서 시도했습니다. 감사 import dispatch._, Defaults._
import