He buscado durante bastante tiempo para entender cómo suscribirme a una matriz cuyos valores se actualizan constantemente.

Necesito entender cómo configurar mi servicio Angular 2+ observable correctamente y suscribirme correctamente en mi componente. Suponga que todas las demás partes del código funcionan correctamente.

 @Injectable() export class AutocompleteService { searchTerm: string; results = []; observe$ = Observable.from(this.results); searchTest(term){ this.searchTerm = term.toLowerCase(); if(this.searchTerm.length > 2){ this.recruiters.forEach(function(el){ if(el.name.toLowerCase().indexOf(term) != -1) { this.results.push(el); } }); } } getCurrentResults():Observable<Object> { return this.observe$; }

Todo en el servicio funciona como se esperaba. Si registro el term , obtengo la entrada del usuario de mi componente. O la matriz de results después de que se inserten los resultados de búsqueda coincidentes.

 @Component({ selector: 'autocomplete', templateUrl: './autocomplete.component.html', providers: [AutocompleteService] }) export class AutocompleteComponent implements OnInit{ constructor(private autocompleteService: AutocompleteService){} value: string = ''; searchControl = new FormControl(); // fired when input happens getResults(event){ this.autocompleteService.searchTest(event.target.value); this.autocompleteService.getCurrentResults().subscribe( value => console.log(value) ); }

Configuré el patrón observable lo mejor que pude, pero no obtengo nada de .subscribe en getResults