ViteClient constructor

ViteClient(
  1. RpcService service, {
  2. TypedSubscribeCallback? subscribeCallback,
})

Implementation

ViteClient(this.service, {TypedSubscribeCallback? subscribeCallback}) {
  api = RpcApi(
    service,
    typeFactory: convertJson,
    subscribeCallback: (data) {
      final response = convertJson<CallbackParam>(data);

      final mapping = subscriptionCallbackMapping[response.subscription];
      if (mapping != null) {
        mapping(response);
        return;
      }

      if (subscribeCallback != null) {
        subscribeCallback(response);
      }
    },
  );
}