rx-scala

0열

1답변

RxJava 1/RxScala에서 다음 상황에서 관찰 할 수있는 소스를 어떻게 조절할 수 있습니까? def fast: Observable[Foo] // Supports backpressure def afterExpensiveOp: Observable[Bar] = fast.flatMap(foo => Observable.from(expensiveO

0열

2답변

두 개의 정렬 된 관측 값 간의 관측 값을 만드는 방법은 무엇입니까?

두 개의 정렬 된 복식을 관찰 할 수 있다고 가정 해 보겠습니다. 나는 그들 사이의 차이점을 관찰 할 수있는 것으로보고 싶습니다. 예를 들어이에 대한 1 2 4 left: ──o───────o───────────o────/ 1 3 4 5 right: ──o────o──o───o───/ l2 r3 r5 out

0열

2답변

RxJava/RxScala에서 observable 캐시하는 방법

RxScala를 기반으로하는 반응성 스칼라 드라이버를 사용하여 mongodb를 호출하는 REST API가 있습니다. 내 API 컨트롤러 또는 서비스 계층에서 , 내가 어떻게 할 수 hazelcast (또는 다른 캐싱 도구) 내 모든 서비스가 비동기입니다 만 관찰 반환, 어떤 생각을 사용하여 MongoDB를 호출을 피하기 위해 캐싱을 사용할 필요가 관찰 할

1열

1답변

배열을 관찰 할 수 있도록 TCP 소켓 켜기 [Byte]

내 Android 앱에서 Socket을 사용하여 바이트 배열을 송수신해야합니다. 편의상 나는 Socket에 연결된 Observable으로 작업하고 싶습니다. 인터넷에서 찾고 나는이 코드를 발견했습니다는 "안녕하세요"문자열을 보낼 때, 예를 들어, 한 번에 import rx.lang.scala.Observable val s = Observable.usin

0열

1답변

onComplete 만 호출했을 때 scala rx observables를 통해 매핑

scala observables를 사용하여 couchbase에서 항목을 가져온 다음 map, flatMap, zip을 사용하여 결과를 변환합니다. 문제는 물건이 couchbase에 없으면 예를 들어 .zip은 onComplete 만 호출되지 않는다는 것입니다. 예 : import rx.lang.scala._ def getIdsWithValues(ids:

0열

2답변

RxScala "zip"다중 Observables

RxScala에서 2 개 이상의 Observables를 "압축"하는 방법은 무엇입니까? val ob1: Observable[Int] = Observable.from(Future(10)) val ob2: Observable[Int] = Observable.from(Future(20)) val ob3: Observable[Int] = Observable.f

0열

1답변

RxJava/RxScala에서 groupBy와 flatMap (maxConcurrent, ...)을 결합합니다.

들어오는 처리 요청이 있습니다. 공유 자원이 고갈되어 동시 처리가 너무 많아지기를 원하지 않습니다. 나는 또한 몇 가지 독특한 키를 공유 요청이 동시에 실행되지 선호하는 것 : 키 당 관찰이 결코 완료하지 않기 때문에 def process(request: Request): Observable[Answer] = ??? requestsStream

2열

1답변

Scalaz 대 ReactiveX

저는 Java에서 ReactiveX 확장으로 2 년 동안 일해 왔지만 지금은 scala로 옮겼습니다. 많은 사람들이 ScalaZ 확장을 사용하여 Scala에서보다 기능적인 프로그래밍을 수행하는 것을 보았습니다. ScalaZ 확장을 사용하는 데 차이가 있습니까? 아니면 내가 수행 한 스칼라에 reactiveX를 적용하고 스칼라로 멋지게 움직이는 지 알고 있습

0열

1답변

RxScala 응용 프로그램에서 Java 라이브러리 (rxjava-extras) 코드를 호출하십시오.

RxScala 응용 프로그램에서 카프카에서 메시지를 소비하고 동적 크기의 슬라이딩 윈도우에서 메시지를 처리하고 싶습니다. 즉, 생성 된 모든 메시지를 그룹으로 묶고 싶습니다. 같은 2 초 안에 RxScala는 내가 아는 한이 종류의 연산자를 제공하지 않습니다. 이 저장소 (https://github.com/davidmoten/rxjava-extras)는 "

2열

1답변

Observable은 무한한 양의 메모리를 사용합니까?

각 Observable에는 최초로 생성 된 값으로 추적 할 수있는 캐시가 있기 때문에이 캐시를 저장하는 데 사용되는 메모리 양은 제한되지 않습니다. Observable.interval(1.microsecond).map(_ => System.currentTimeMillis) .subscribe(x =>()) 을 그리고 응용 프로그램이 실행되는 동