reactive-programming

0열

1답변

takeUntil에서 관측 가능한 값을 얻는 방법

드래그 앤 드롭과 유사하지는 않지만 비슷한 작업을하고 있습니다. 클릭> 미리보기를 위해 운동 추적> 다시 클릭시 추적 중지> 마지막 클릭으로부터 메타 데이터 얻기 그러나 사용자는 여러 가지를 클릭하여 추적을 중지 할 수 있으며 클릭 한 두 번째 항목에 따라 부작용이 다르기 때문에 그 내용을 알고 싶습니다. 기본적으로 , 그 clickSomething$ =

javascript reactive-programming rxjs5 2017-05-04

---

0열

1답변

어떻게 그룹화 된 관측 값을 올바르게 재결합합니까?

저는 주가 분석을위한 도구를 만들려고합니다. 다른 주식에 대한 가격 데이터 스트림이 있는데, 새롭고 별개의 완전한 가격 집합을받을 때마다 이벤트를 내 보내고 싶습니다. 내 계획 : 다른 주식에 대한 스트림을 다른 하위 스트림으로 그룹화하고 최신 값을 재결합합니다. a_source = price_source.filter(lambda x: x['stock']

python-3.x system.reactive reactive-programming reactivex rx-py 2017-05-06

---

1열

1답변

RxJava2에서 관측 가능한 N 개의 마지막 객체 가져 오기

일부 숫자를 방출하는 Observables가 있으며 단순히 마지막 N 개의 요소를 가져 가고 싶습니다. (단순히 RxJava에 대한 래퍼입니다 내가 RxKotlin을 사용하고 있습니다) 나는 다음 한 코드 : I 가까이 버퍼 연산자의 반환, 나는 이것을보고 어떤 모습으로 val list = listOf(1,2,3,4,5,6,7,8,9,10) Observa

java kotlin reactive-programming rx-java2 rx-kotlin 2017-05-06

---

1열

1답변

combineEpics와 같이 작동하지만 네임 스페이스를 기반으로 서사시를 선택하는 메타 서사시 만들기

네임 스페이스 내 서사시. 기본적으로 내 서사시를 결합하고 싶지만 사용 된 서사시는 내 상태에 설정된 네임 스페이스에 따라 달라집니다. 내가 지금까지 여기 왔 :이 첫 번째 조치에 대해 작동 const epics = { 'ns1': nameSpace1Epic, 'ns2': nameSpace2Epic, 'default': (acti

javascript rxjs reactive-programming reactive 2017-05-08

---

1열

1답변

Project Reactor composing Flux.zip()

이 작은 응용 프로그램으로 Project Reactor 3.0을 배우려고 노력했습니다. 필자는 Flux.zip() 함수를 작성하여 Movie 객체에 변수를 결합하는 데 어려움을 겪고 있습니다. Reactor에서는 반환 유형이 Flux<Tuple5<>> 인 것 같습니다. RxJava2에서는 Function5<>을 반환합니다. RxJava2 Single<Mov

java reactive-programming rx-java2 project-reactor spring-webflux 2017-05-08

---

0열

2답변

각도로 객체의 여러 배열 속성에서 여러 http 호출을 수행하려면 어떻게해야합니까?

나는 각도를 배우고 있으며 나는 여전히 관찰 할 수있는 것들에 머리를 감싸려고 노력하고있다. 내 응용 프로그램에서는 "objects"라는 개체 배열 속성과 "photos"라는 개체 배열 속성이 (다른 속성들 사이에있는) Project 개체를 반환하는 API 호출을합니다. 각 사진에는 차례대로 "referenceImageUrl"이라는 속성과 "captured

angular rxjs reactive-programming observable 2017-05-08

---

2열

1답변

react-redux 앱에서 초기 동작을 효과적으로 전달하는 방법은 무엇입니까?

내 응용 프로그램에이 코드가 있습니다. componentWillMount() { if(!this.props.posts.request.sending && this.props.posts.items.length == 0) { this.props.fetchData({ page: this.props.posts.request.page

reactjs redux react-redux reactive-programming 2017-05-09

---

1열

1답변

RxJS가 mergeMap과 함께 실행되지 않음

다음 예제에서 onComplete 콜백이 실행되지 않는 이유가 궁금합니다. 다음 콜백은 예상대로 실행됩니다. foo에 의해 생성 된 observable 안에 오류가 발생하면 오류 콜백도 실행됩니다. 전체 콜백 만 실행되지 않습니다. JSBin : 나는 푸에 의해 반환 관찰에 직접 가입하면 예상대로 http://jsbin.com/punoridajo/edit?

reactive-programming observable rxjs5 2017-05-09

---

1열

1답변

RxJava 타이머 및 제한 시간이 포함 된 중첩 구독

RxJava2를 사용하여 일부 시간 제한 이벤트를 수행하려고합니다. 1 초 이내에 완료 할 수있는 비동기 이벤트가 몇 개 있으며 비동기 작업의 결과를 계속하기 전에 사용자에게 적어도 1 초 동안 메시지를 표시하려고합니다. 그 결과는 나중에). 비동기 작업 또한 시간 초과 될 수 있으며 계속 메시지를 표시하고 계속하고 싶습니다. zip() 타이머를 첫 번째

java asynchronous timeout reactive-programming rx-java2 2017-05-09

---

0열

1답변

동시에 듣고있는 동안 subscribe 함수를 주기적으로 호출하십시오.

실례 합니다만 실례 합니다만 Reactive extensions에 약간의 경험이 있습니다. 내가 원하는 것은이 같은 것입니다 : 항목을 항상 방출이 관측 주어진 myObservable.Do(d => myObserver.OnNext(d)).Interval(someTime).subscribe({ Run the this code periodically with

c# asynchronous system.reactive reactive-programming 2017-05-10

---