|
|
@ -17,7 +17,7 @@ |
|
|
import { Component, ElementRef, forwardRef, Input, OnChanges, OnInit, SimpleChanges, ViewChild } from '@angular/core'; |
|
|
import { Component, ElementRef, forwardRef, Input, OnChanges, OnInit, SimpleChanges, ViewChild } from '@angular/core'; |
|
|
import { ControlValueAccessor, FormBuilder, FormGroup, NG_VALUE_ACCESSOR, Validators } from '@angular/forms'; |
|
|
import { ControlValueAccessor, FormBuilder, FormGroup, NG_VALUE_ACCESSOR, Validators } from '@angular/forms'; |
|
|
import { Observable, of, ReplaySubject } from 'rxjs'; |
|
|
import { Observable, of, ReplaySubject } from 'rxjs'; |
|
|
import { debounceTime, map, share, switchMap, tap } from 'rxjs/operators'; |
|
|
import { catchError, debounceTime, map, share, switchMap, tap } from 'rxjs/operators'; |
|
|
import { Store } from '@ngrx/store'; |
|
|
import { Store } from '@ngrx/store'; |
|
|
import { AppState } from '@core/core.state'; |
|
|
import { AppState } from '@core/core.state'; |
|
|
import { TranslateService } from '@ngx-translate/core'; |
|
|
import { TranslateService } from '@ngx-translate/core'; |
|
|
@ -201,6 +201,7 @@ export class SlackConversationAutocompleteComponent implements ControlValueAcces |
|
|
fetchObservable = of([]); |
|
|
fetchObservable = of([]); |
|
|
} |
|
|
} |
|
|
this.slackConversetionFetchObservable$ = fetchObservable.pipe( |
|
|
this.slackConversetionFetchObservable$ = fetchObservable.pipe( |
|
|
|
|
|
catchError(() => of([])), |
|
|
share({ |
|
|
share({ |
|
|
connector: () => new ReplaySubject(1), |
|
|
connector: () => new ReplaySubject(1), |
|
|
resetOnError: false, |
|
|
resetOnError: false, |
|
|
|