cyworld

RxJS 구독() 함수의 구성요소로 선언된 액세스 변수 나는 사용할 수 있다.this.variable다음과 같은 RxJS 함수 내부를 제외하고 구성 요소의 임의 부분에 있는 변수에 액세스하기 위해subscribe()또는catch(). 아래 예에서 프로세스를 실행한 후 메시지를 인쇄하려는 경우: import {Component, View} from 'angular2/core'; @Component({ selector: 'navigator' }) @View({ template: './app.component.html', styles: ['./app.component.css'] }) export class AppComponent { message: string; constructor() { this.messa..

환원 관측 가능에서 여러 작업을 전송하는 방법? 나는 환원 관측할 수 있는 서사시에서 여러 가지 행동을 파견하고 싶다.어떻게 하면 좋을까?나는 원래부터 시작했다. const addCategoryEpic = action$ => { return action$.ofType(ADD_CATEGORY_REQUEST) .switchMap((action) => { const db = firebase.firestore() const user = firebase.auth().currentUser return db.collection('categories') .doc() .set({ name: action.payload.name, uid: user.uid }) .then(() => { return { type: ADD_CA..

rxjs가 있는 사용 가능한 Buffer를 생성하는 방법 5 나는 내가 생각하기에 사용 가능한 버퍼로 만들려고 노력하고 있다. 나는 이것을 위해 그들의 코드를 누군가 공유하게 했지만, 어떻게 그것을 사용자 정의 작업으로 바꿀 수 있는지 이해할 수 없다. (형식 없이/ 단지 ES6만). const attach = Rx.Observable.timer(0 * 1000, 8 * 1000).mapTo('@'); const detach = Rx.Observable.timer(4 * 1000, 8 * 1000).mapTo('#'); const input = Rx.Observable.interval(1* 1000); const pauser = attach.mapTo(true).merge(detach.mapTo(fals..

Typecript / Angle2: 관측 가능 & JSONP와 상호 작용하는 캐스트 JSON 내가 만든 인터페이스에 json 어레이를 캐스팅하여 브라우저에 표시하려고 한다.내 인터페이스에 뭔가 문제가 있는 것 같은데 잘 모르겠어...코드를 실행하려면 무엇을 변경해야 하는가? 인터페이스: export interface Video { id: number; name: string; description: string; createdAt: string; } app.ts import {JSONP_PROVIDERS, Jsonp} from '@angular/http'; import {Observable} from '../../../node_modules/rxjs'; import 'rxjs/add/operator/ma..

순차적으로 관찰 가능성과 하나의 결과 도출 다음 기능을 사용하여 병렬로 실행하는 일련의 관찰 가능: let observables: Observable[] Observable.forkJoin(observables) 그러나 이것은 완벽하게 작동하지만, 나는 순차적으로 관찰 가능성의 배열을 실행해야 하며, 마지막 관찰 가능이 완료된 경우에만 하나의 결과를 내보내야 한다.그때 나는 사용하려고 했다. Observable.concat(observables) 그러나 이것은 내가 포크조인을 사용할 때 얻을 수 있는 하나의 결합 결과뿐만 아니라 여러 개의 결과를 반환한다.그래서 나는 사실 둘의 조합이 필요해. 다음과 같이 순차적으로 실행하기 위해 축소 기능을 사용하려고 노력했다. return observables.red..

관찰 가능한 테이크아웃 취소작동하지 않을 때까지 자동 완성 HTTP 호출과 검색 HTTP 호출 실행...실행 작업이 트리거될 때 자동 완성 호출을 중단해야 한다.내가 지금 하고 있는 것은 다음과 같은 주제를 사용하는 것이다. private onExecute$ = new Subject(); 자동 완성 방법: executeAutoComplete(e) { this.myService.searchAutoComplete(e.criteria) .pipe( takeUntil(this.onDestroy$), takeUntil(this.onExecute$), map( // continue with more code 그리고 내 실행 방법에서 신호를 올린다: executeSearch(e) { console.log('trigg..

rxjs: Error: 순서대로 요소 없음 나는 실수를 하고 있다. localhost:8080으로 이동할 때 'emptyError: sequence에 요소가 없음' 오류 발생. 나는 어린이 경로를 만드는 동안 순서에 따라 요소가 없지만 어떤 답변도 적용되는 것 같지 않은 Eargulation 5 Error라는 스레드를 본 적이 있다. 있습니다"rxjs": "^5.5.6"그리고 내 경로에서, 나는 추가하기 위해 노력했다.pathMatch: 'full',그러나 오류는 여전히 표시된다. 앱 라우팅 모듈.ts 추출 const routes: Routes = [ { pathMatch: 'full', /* added recently for test purposes*/ path: '', component: RootCo..

ngFor 비동기 파이프에 관측 가능이 아닌 관측 가능이 필요한 이유 다음과 같은 템플릿이 있다. *ngFor="let contact of contacts | async" 위치: contacts: Observable; 다음 오류가 발생하는 경우: ERROR Error: Cannot find a differ supporting object '[object Object]' of type 'object'. NgFor only supports binding to Iterables such as Arrays. ngFor 비동기 파이프에 필요한 이유Observable대신에Observable?이것은 그 때문은 아니다.async파이프를 치다 그contacts관측 가능은 배열 대신 물체를 방출하며, 당신은 물체를 반복할..

각도 6 zip이 더 이상 사용되지 않음: resultSelector가 더 이상 지원되지 않음, 파이프에서 맵으로 각도 6 zip은 사용되지 않음: tslint는 다음과 같은 메시지를 제공한다. zip is deprecated: resultSelector is no longer supported, pipe to map instead 다음 코드를 업그레이드하는 방법: import {interval, from, zip} from 'rxjs'; let testArray = [1, 2, 3, 4, 5]; array$ = from(testArray); inter$ = interval(1000); numbersOverTime$ = zip(array$, inter$, (item, i) => item); 간단히 파이프..

RxJS: shareReplay에서 bufferSize란? 무슨 말인지 모르겠다.bufferSize매개 변수 평균 및 그 영향은 무엇인가? 다음의 차이점은 무엇인가? var published = source .shareReplay(); var published = source .shareReplay(0) var published = source .shareReplay(1); var published = source .shareReplay(10); 버퍼 크기: BufferSize는 캐시되고 재생된 항목의 수를 의미한다. 가입 시 특정 배출량을 재생한다. 구독자가 없는 경우에도 캐시된 항목 유지 문제 제기: var published = source .shareReplay(); 이것에 대한 어떤 가입자도 소스..