RXDart operador asyncMap com chamada de API

asyncMapApiCall.dart

void main() async {

final behavior = new BehaviorSubject<String>();
 
 // pegando cada valor adicionado ao Observable, fazendo uma requisição em uma Api externa e retornando uma lista de resultados
 // assim transformando um simples texto em uma lista de resultados vindos da Api
 
 Observable<List> newStream = behavior
    .asyncMap((value) => Api.searchProducts(value));
 
 // ouve o novo Observable criado
 newStream.listen(print);
  
}