patrick-entinux

import { ApiResponse } from '@elastic/elasticsearch';
import {
  TransportRequestCallback,
  TransportRequestOptions,
} from '@elastic/elasticsearch/lib/Transport';
import { Observable } from 'rxjs';

/**
 * Use ElasticSearch API with RxJS observables that can be
 * cancelled. Observables are cold -- they must be subscribed to make