prostudy

RxJS6 asObservable()이 주제에 필요한가? 언제인가asObservable()대상(예: 행동 대상)에 해당 대상을 관찰할 수 있는 권한이 필요한가?그 주제는 또한 관찰할 수 있는 것에 던져질 수 있다. 문의사항 사이의 기술적 차이점은 무엇인가?name1$그리고name2$? 어느 것을 사용해야 하는가(어느 것name1$또는name2$)? 코드 샘플 import { Observable } from 'rxjs/Observable'; import { BehaviorSubject } from 'rxjs'; export class Person { private nameSubject: BehaviorSubject = new BehaviorSubject('lorem'); public get name1$()..

rxjs 관찰 가능 .map 실행되지 않음 나는 관찰 가능한 데이터를 반환하는 다음 코드가 있다. 이 코드가 유효한 JSON인지 확인하고 그렇지 않으면 URL에서 가져오려고 한다.착취와 모든 것이 통한다. load():Observable { return Observable.create(observer => { if (this.needsFetch) { var data; this.http.get(this.data) .map(res => { var result = res.text(); // console.log(result); try { data = JSON.parse(result) } catch (e) { return Observable.of([{error:"ERROR LOADING JSON: " + thi..

동작부제: 다음이 함수가 아님 형제자매 구성 요소 간에 데이터를 공유하고 공유 서비스를 통해 공유하려고 한다.첫 번째 구성요소가 로드되면, 내 API에서 서버 목록을 검색하고 검색된 모든 서버로 선택 상자를 채운다.이제 사용자가 새 서버를 선택할 때 다른 구성요소에 알려 세부사항을 표시하도록 하십시오. 이건 내 임무야. @Injectable() export class DashboardService { servers: Server[] = []; selectedServer = new BehaviorSubject(null); setServers(servers: Server[]) { this.servers = servers; } } 선택 상자가 있는 구성 요소: @Component({ selector: 'app..

각도 2 - 관찰 가능한 RxJS의 간격을 변경하는 방법 가져올 데이터를 새로 고치기 위해 rxJS 관찰 가능 간격을 사용하고 있다.간격 설정을 변경하는 방법을 알 수 없다.나는 rxJS에서 제공하는 과목 수업을 사용하는 것에 대해 뭔가를 보았지만, 그것을 작동시킬 수가 없다. 나는 이 플렁크에서 간단한 예를 제공했다. AppComponent에서 나는 이 방법을 가지고 있다. getTime() { this.timeService.getTime(this.refreshInterval) .subscribe(t => { this.currentTime = t; console.log('Refresh interval is: ' + this.refreshInterval); } ); } 그리고 서비스 컴포넌트에 나는 현재..

각도 관찰 가능 - 구독이 없을 경우 구독을 취소해야 하는가? 나는 최신의 각 8을 사용하고 있고 관찰 가능성의 개념은 생소하다.내가 직접 관찰 가능한 사람에게 전화를 걸어 구독 변수에 적용하지 않는 경우, 여전히 구독을 취소할 필요가 있는지 묻는 질문.아래는 구독을 취소해야 하는지 알고 싶은 시나리오인가?미리 감사 드려요 시나리오 1 - 구성 요소에서 httpService 호출: Service - httpService getContactsHttp(){ let headers: any = new HttpHeaders(this.authService.getHeadersClient()); return this.httpClient.get('/contacts', {headers: headers}) .pipe(tim..

Rxjs: 관찰 가능의 차이점.첫 번째 대 단일 대 필터 나는 RxJS 라이브러리를 탐험하고 있는데, Promise 대신 Observable을 사용하는 것을 정말 좋아한다.그러나, 누군가가 사용의 차이에 대한 자세한 정보를 제공할 수 있는가? 관측할 수 있다.먼저 관측할 수 있다.싱글 단일 항목만 반환하도록 필터 적용 이 도서관에서 특별히 싱글이 필요한 것은?필터로 다음을 가리키는 경우: let emitted = false; obs = obs.filter(x => { if(emitted) { return false; } else { emitted = true; return true; } }); 필터(이 경우 위의 코드를 확인하십시오.) 첫 번째 항목이 나타나는 즉시 방출됨.이후의 모든 항목을 무시함.관측..

ngOnInit 내에서 구독자를 점화하지 않는 각도 재스민 테스트 기본 구성 요소 클래스가 있으며 ngOnInit 내에서 서비스 콜에 가입함 ngOnInit() { this.activityService.getActivities().subscribe(activities => { console.log('inside sub'); this.recentActivities = activities; }); } 그래서 나는 이 구독이 실행되는지 알아보기 위해 이 console.log를 포함시켰다. 내 시험에서 나는 내가 필요로 하는 데이터의 관찰 가능한 컬렉션을 반환하기 위해 이 활동 서비스 방법을 감시한다.그리고 시험에서, 나는 모든 고정장치를 한다.detectChanges() 거래를 감지하고 내 배열이 길이 1이 ..

RxJS v5를 사용하여 새로운 Observable(observer) { ...을(를) 어떻게 반환하십니까? 나는 내 기능이 돌아오는 모든 약속을 옵서버블로 대체하려고 한다.이 게시물을 통해 나는 더 이상 "관측 가능한" 관측 가능한 새로운 것을 사용하지 말아야 한다는 것을 배웠다.포크조인 및 배열 인수 비동기식 대기를 달성하기 위한 RxJS v5 구문이란 무엇인가? thirdFunction() { let _self = this; return new Observable(function(observer) { ... observer.next( responseargs ); observer.complete(); }); } 네가 해줄 수 있는 도움에 정말 고마워.다양한 사용 사례에 대해 관찰할 수 있는 일련의 방..

에픽에서 동일한 통화를 두 번 시작하는 것을 방지하는 방법 내 서사시는 그 때 잠에서 깨어난다.REMOTE_DATA_STARTED액션이 전송되고 다음 명령을 사용하여 데이터 가져오기action.url그리고action.owner. 동일한 소유자/url에게 두 번의 동시 통화를 시작하지 않도록 해야겠습니다.소유자/url에 대한 호출이 완료되면 나중에 동일한 소유자/url에 대해 다른 호출을 시작해도 괜찮다. 기존 요청을 취소하고 싶지 않기 때문에 취소는 여기서 찾는 것이 아니며, 새 요청을 시작하는 것을 방지하고 싶다. 나는 혼혈이 필요한 것 같다.exhaustMap그리고groupBy, 하지만 여기서 어디로 가야 할지 모르겠어. 이 시점에서 이건 내 서사시야, 모든 동시통화를 거부하지, 소유자/url에 의한..

RXJS: 스로틀시간 + 마지막 값 나는 짧은 시간 안에 많은 이벤트를 스트림에 보낼 수 있는 시나리오를 가지고 있다.나는 일종의 혼용된 연산자를 갖고 싶다.debounceTime그리고throttleTime. 다음의 데모들은 내가 무엇을 갖고 싶은지 설명하는데 사용될 수 있다. https://stackblitz.com/edit/rxjs6-demo-jxbght?file=index.ts.구독자가 첫 번째 이벤트를 받은 다음 x ms를 기다리길 바란다.대기 시간 중에 더 많은 이벤트가 방출된 경우, 마지막 이벤트는 대기 시간 이후 가입자에게 전송되어야 한다.대기 시간은 디바운스가 하는 것과 마찬가지로 각각의 새로운 방출 이벤트에서 재설정되어야 한다. 1초 이내에 버튼을 3번 클릭하면 1과 3이 인쇄된다.그런 ..