How to use stream in riverpod?

[chuppasik]

I created a flutter web project and would like the data on the user's screen to be up to date. I created a stream using riverpod, but when I change the value in the database, the data on the screen is not updated. To see the latest data, I need to refresh the page manually.

lass UserController {
  /// Controller for user related actions.
  UserController(this.ref);

  final Ref ref;

  Future<AppUser?> getCurrentUser() async {
    final client = ref.read(clientProvider);
    return await client.appUser.getCurrentUser();
  }
}

@riverpod
UserController userController(Ref ref) => UserController(ref);

@riverpod
Stream<AppUser?> currentUser(Ref ref) async* {
  yield await ref.watch(userControllerProvider).getCurrentUser();
}

class TestScreen extends StatelessWidget {
  const TestScreen({super.key});

  @override
  Widget build(BuildContext context) {
    return Consumer(
        builder: (BuildContext context, WidgetRef ref, Widget? child) {
      return AsyncValueWidget(
        value: ref.watch(currentUserProvider),
        data: (user) {
          if (user == null) {
            return serverError;
          }
          return Text(user.testdata.toString());
        },
      );
    });
  }
}

How can I ensure that the value is updated when the data in the database changes?

[EvgrafovBTW]

Please show how you setting and getting data from riverpod provider

[chuppasik]

The question is relevant. I tried Stream, Future, but they behave the same.

[ciprig]

@riverpod
Stream<AppUser?> currentUser(Ref ref) async* {
  yield await ref.watch(userControllerProvider).getCurrentUser();
}

This creates a stream with one emission that is the same as the future. It would help if you got a stream from the database. getCurrentUser needs to return a stream.