StreamProvider inspection.

stream_provider_inspection.dart

import 'package:riverpod/riverpod.dart';

final originalStream = StreamProvider.family.autoDispose<String, String>((ref, prefix) {
  return Stream.value('$prefix foo');
});

final prefixStore = StateProvider.autoDispose<String?>((_) => null);

final originalListener = StreamProvider.autoDispose<String>((ref) {
  final prefix = ref.watch(prefixStore);
  if (prefix == null) {
    return const Stream.empty();
  }
  
  return ref.watch(originalStream(prefix).stream);
});

void main() async {
  final container = ProviderContainer();
  
  final value = await container.read(originalStream('#').future);
  print('first value: $value');
  
  container.listen(
    originalListener,
    (_, value) {
      print('$value');
    },
    fireImmediately: true,
  );
  
  container.read(prefixStore.notifier).state = '#';
  
}