prostudy

이전에 방출된 값을 기준으로 실행 방지 자동 검색에서 빈 검색 결과를 얻는 경우 노로 다운된 검색 쿼리를 사용한 후속 쿼리는 차단되어야 한다.예: '빨간색'에 대한 검색이 비어 있는 경우, '빨간색'에 대한 검색은 의미가 없다. 쌍방향()과 스캔() 연산자를 사용해 보았다.코드 조각: import { tap, switchMap, filter, pairwise, scan, map } from 'rxjs/operators'; this.searchForm.get('search').valueChanges .pipe( switchMap( queryString => this.backend.search(queryString)) ) .subscribe() 간단한 시나리오가 지정된 업데이트:뒷말에는 '사과'라는 말밖에 ..

브라우저가 최소화된 경우 직렬 포트의 데이터 전송 나는 내 웹 앱에서 웹 시리얼을 사용하고 싶다.내가 가지고 있는 한 가지 문제는 사용자가 브라우저를 변경하거나 최소화할 때 데이터 송수신을 위한 타이머가 중지된다는 것이다.나는 웹 작업자를 테스트해서 이것을 받았다. 어떻게 하면 이것을 고칠 수 있을까? 내 코드는 이렇고 rxjs 타이머를 사용한다. //user give access to serial port const port = await navigator.serial.requestPort(); await port.open({ baudRate: 9600 }); const textDecoder = new TextDecoderStream(); const readableStreamClosed = port.r..

'Next' 속성이 'Observable

각도 4 Ngx-datable Filter 미작동 객체가 null이지만 액세스됨(조건이 있는 경우에도) ngx-datable을 사용하고 있는데 코드에 필터 기능을 추가하려고 했는데 전혀 작동이 안 돼. 이게 내 암호야: import {Component, OnInit, ViewChild, ViewEncapsulation} from '@angular/core'; import {NavbarService} from '../../Services/navbar.service'; import {DataService} from '../../Services/data.service'; import {DatatableComponent} from '@swimlane/ngx-datatable'; import {forEach} f..

rxjs 단위로 구독당 한 번 관측 가능한 파이프에서 초기화 로직을 수행하는 방법 그래서 나는 이 관찰 가능한 파이프를 가지고 있는데, 당신이 사용할 수 있는 것처럼, 구독 초기에 한 번 수술을 해야 한다.finalize()구독이 끝날 때 한 번 수술을 하다 그래서 이렇게 시작했는데 불행히도 스타트업은 한 사람당 한 번씩 할 겁니다.next()그 문제를 논하다 const notificationSubject = new BehaviorSubject(undefined); const notifications$ = this.notificationSubject.pipe( tap(() => startup()), filter(isValueDefined), finalize(() => shutdown()) ); notif..

(null이 없는) 두 스트림을 병합하여 쌍에 조건을 적용하는 방법 나에게 두 개의 데이터 스트림이 있다고 생각해 보십시오. 데이터 스트림을 병합하여 이 두 스트림 사이에 데이터 조건을 적용할 수 있는 방법이 있는가?예를 들면 Stream A : A, B, C, D.... Stream B : -, A, -, -.... Composed : (A,-),(B,A),(C,-),(D,-).... rxjs를 사용하여 위에서 합성 스트림을 만드는 방법?나는 몇 가지 알림을 올리기 위해 합성된 스트림에 조건을 적용하고 싶다.또한 마지막으로 알려진 Null이 아닌 데이터를 사용할 수 있는가? 예를 들어 아래의 합성 스트림을 참조하십시오. Stream A : A, B, C, D.... Stream B : 1, null, ..

rxjs 가변 응답 시간을 가진 엔드포인트의 주기적 폴링 나는 1초에 한 번 이상, 그리고 끝점을 폴링하는 데 걸리는 시간보다 더 느리지 않게 끝점을 폴링하고 싶다.한 가지 이상의 미결 요청이 있어서는 안 된다. 나는 적어도 1초에 한 번 엔드포인트를 폴링할 수 있는 반응형 프로그래밍 방식을 원하지만 엔드포인트가 1초 이상 걸리면 다음 요청은 즉시 실행된다. 아래 대리석 도표에서 2차, 3차 요청은 1초 이상 걸리지만 4차, 5차 요청은 더 빨리 마무리된다.다음 요청은 1초 경계에서 발생하거나 마지막 미결 요청으로부터 데이터를 얻는 즉시 발사된다. s---s---s---s---s---s---| # 1 second interval observable r---r----r--------r-r---| # end..

각도 + Redex/ngrx: 상태 업데이트 대 양식 일부 컨텍스트 먼저 사용: 선택자를 다시 선택하다. 정규화 및 표준화를 위한 Normalizr ngrx/스토어(Redex의 사후 대응적 구현)는 상태 관리를 위해 반응하는 현실 세계의 예와 유사하게, 나는 실체들에 대한 한 조각의 국가를 가지고 있다. 이것은 실제로denormalize()기사의 작업방법은 다음과 같은 것을 가질 수 있기 때문이다.author또는media모두 실체일 수도 있어 그 말은 예를 들어 싱글을 고를 때user내 주(州)에서, 나는 이 전지구적 실체를 움켜쥐고 있어, 내 선택기는 이와 비슷한 모양이야. export const getOne = createSelector( getAllEntities, getDetailId, (enti..

Object.observe 철수 및 RxJS 및 각도 2 나는 약간 혼란스럽다. 왜냐하면 Obejct.observe가 ES2016에서 탈퇴한다고 하기 때문이다. 반면에 Angular Connect에 대한 논의는 그들이 그것에 의존할 것이라고 언급한다. 그래서 나는 각도 2가 직접적으로 Object.observe에 의존하지 않고 Object.observe를 사용하는 RxJS에 의존한다는 것을 이해한다. 이 철수의 영향을 이해할 수 있도록 도와주시겠습니까? 나는 또한 이것이 기능적 반응성 자바스크립트 개발에 어떤 영향을 미칠지 혼란스럽다. 바보같은 질문이라면 미안하지만, 이 모든 개념들은 나에게 정말 새롭다. RxJS는 Object.observe에 의존하지 않는다(그리고 Afaik은 미래에 그렇게 할 의도가..

관찰 가능한 캐스팅 결과.각 2에서 각 유형별로 포크조인 내가 Angle 2에 페이지가 표시되기 전에 서버로부터 2가지 다른 것을 로드해야 하는 컴포넌트가 있다고 하자.나는 그 모든 것들을 끄고 그들이 그 페이지가 Loaded = true라고 다시 말할 때 한 이벤트 핸들러를 불러주길 바란다.내가 이렇게 생긴 서비스 클래스가 있다고 가정해보자. export class MyService { getStronglyTypedData1(): Observable{ return this.http.get('http://...').map((response:Response) => response.json()); } getStronglyTypedData2(): Observable{ return this.http.get('h..