HasuraConnect constructor

HasuraConnect(
  1. String url, {
  2. int? reconnectionAttempt,
  3. List<Interceptor>? interceptors,
  4. Map<String, String>? headers,
  5. Client httpClientFactory()?,
})

Implementation

HasuraConnect(
  this.url, {
  this.reconnectionAttempt,
  List<Interceptor>? interceptors,
  this.headers,
  http.Client Function()? httpClientFactory,
}) {
  startModule(httpClientFactory);
  _interceptorExecutor = InterceptorExecutor(interceptors);

  _subscription = controller.stream
      .where((data) => data is Map)
      .map((data) => data as Map)
      .where((data) => data.containsKey('id'))
      .where((data) => snapmap.containsKey(data['id']))
      .listen(rootStreamListener);
}