build method

  1. @override
Future build(
  1. String arg
)

Implementation

@override
Future<ffi.RsvpStatusTag?> build(String arg) async {
  final client = ref.watch(alwaysClientProvider);
  _listener =
      client.subscribeStream('$arg::rsvp'); // keep it resident in memory
  _listener.forEach((e) async {
    state = await AsyncValue.guard(_getMyResponse);
  });
  return await _getMyResponse();
}