system.reactive

1열

1답변

그래서 현재 사용자가 반환 한 Observable 가지고 : public Observable<Account> getLoggedUserInfo() { try { return accountService.me(preferencesHelper.getToken()).concatMap(remoteAccount -> { return

4열

3답변

함수에서 Observable을 만드는 방법은 무엇입니까?

함수를 (동 기적으로) 호출 한 다음 그 반환 값을 초기 방출로 사용하고자합니다 (결과적으로 관찰 가능한 결과에 대해 다른 연산자를 연결 함). 구독 중에이 함수를 호출하고 싶습니다. 따라서 Observable.of(() => getSomeValue())을 사용할 수 없습니다. 나는 bindCallback (이전 fromCallback)을 보았지만,이 작업

0열

1답변

스트림의 오브젝트가 관찰 가능인지 확인합니다.

objectStream의 forEach 메소드에서 리턴 된 오브젝트가 옵저버인지 확인하고 싶습니다. typeof를 시도했지만 분명히 작동하지 않습니다. 아래의 스 니펫을 찾으십시오. var Observable = Rx.Observable; var button = document.getElementById('button'); var click

0열

1답변

RxJava Observable, emit on demand

내 안드로이드 응용 프로그램에서 나는 사용자의 사진 목록을 보여줍니다. 사진은 서버에 보관되며 사진의 양은 매우 클 수 있습니다. 사용자가 사진을 보여달라고 요청하면 애플리케이션은 서버에서 먼저, 즉 10 장의 사진을 가져옵니다. 그런 다음 사용자는 다음 10 개를 표시하도록 요청하고 응용 프로그램은 10 개 더로드하는 등의 작업을 수행합니다. rx.Obs

3열

1답변

Rx 및 C에서 SQL Server 테이블을 관찰 가능하게 만들기

SQL Server 데이터 테이블을 스트리밍하는 Rx.NET의 잠재력에 대해 연구 중입니다. 기본적으로 폴링에 의지하지 않고 가능한 한 데이터를 삽입 할 때 데이터를 가깝게 만들고 싶습니다. Rx/DataReader를 사용하여 일부 POC를 만들었지 만 새로운 행이 삽입되면 구독 할 수 없습니다. 선택할 행이 더 이상 없을 때 스트림이 중지되었습니다 (물론

2열

1답변

파일 다운로드 현재 내가 파일을받을하기 위해이 코드를 사용하고

: WebClient webClient = new WebClient(); webClient.DownloadProgressChanged += webClient_DownloadProgressChanged; webClient.DownloadFileCompleted += new AsyncCompletedEventHandler(webClient_ProgressC

0열

1답변

내 라이브러리에서 Reactive Extensions를 인식해야합니까?

Reactive Extensions for .NET에 대한 관심이 점점 더 커지고 있습니다. 내 응용 프로그램에는 데이터 수집 시스템이 포함되어 있으므로 대부분 도메인 클래스 라이브러리의 핵심 클래스와 개념까지도 Rx 개념을 사용하면 이익을 얻을 수 있습니다. 내 도메인 모델이 Rx 유형 및 인터페이스로 "오염"되어 있어야합니까? 아니면 클라이언트 코드에서

2열

1답변

Reactive Extension 및 트랜잭션 ODP.NET을 사용하여 Oracle AQ 콜백

Oracle AQ에서 메시지를 dequeuing하고이를 IObservable로 시스템에 표시했습니다. 워크 플로는 다음과 같습니다. - 응용 프로그램은 새 메시지에 대해 Oracle에서 콜백 이벤트를받습니다. 응용 프로그램은 메시지를 큐에서 삭제하고 IObservable에 추가합니다 (메시지는 대기열에서 메시지가 제거되는 즉시 커밋되는 트랜잭션의 일부로 대

2열

1답변

RX GroupByUntil sliding with Until

나는 GroupByUntil을 사용하여 훌륭하게 작동하는 특정 속성 값을 가진 MSMQ의 메시지를 그룹화합니다. 이 코드를 사용하고 있습니다. observable.GroupByUntil( message => message.Source, message => message.Body, message => Observable.Timer(n

2열

1답변

onCompleted 및 onNext에 도달하지 않았습니다.

이벤트에서 Observable을 생성하기 위해이 메서드를 만들었습니다. private void BuildObservables(WebClient webClient) { Observable.FromEventPattern<AsyncCompletedEventHandler, AsyncCompletedEventArgs>(h => webClient.Downl