connect method

dynamic connect()

Implementation

connect() {
  String url =
      "${networkResponse.dio.options.baseUrl}/sdk/v1/events/connect?apiKey=${Uri.encodeComponent(apiKey)}";

  EventFlux eventFlux = EventFlux.spawn();
  eventFlux.connect(
    EventFluxConnectionType.get,
    url,
    header: {
      'x-sdk-version': '1.0.0',
      'x-sdk-platform': 'mobile',
      ...?header,
    },
    onConnectionClose: () {
      connected = false;
      handleDisconnect?.call();
    },
    onError: (e) {
      connected = false;
      handleConnectionError?.call(e);
    },
    autoReconnect: reconnectConfig != null,
    reconnectConfig: reconnectConfig,
    onSuccessCallback: (eventFluxResponse) {
      connected = true;
      _streamSubscriptionSSEModel = eventFluxResponse?.stream?.listen(
        _handleIncomingEvent,
        onError: (e) {
          connected = false;
          handleConnectionError?.call(e);
        },
        onDone: () {
          connected = false;
          handleDisconnect?.call();
        },
      );
    },
  );
  // _streamSSEModel = SSEClient.subscribeToSSE(
  //   method: SSERequestType.GET,
  //   url: url,
  //   header: {
  //     'x-sdk-version': '1.0.0',
  //     'x-sdk-platform': 'mobile',
  //     ...?header,
  //   },
  // );

  // _streamSubscriptionSSEModel = _streamSSEModel?.listen(
  //   _handleIncomingEvent,
  //   onError: (e) {
  //     connected = false;
  //     handleConnectionError?.call(e);
  //   },
  //   onDone: () {
  //     connected = false;
  //     handleDisconnect?.call();
  //   },
  // );
}