streamProvider and stream.listen

[AndroidDesigner]

Hello everyone.
I have a TCP socket so that messages are coming from server every 1 second for different scenarios.
I want to use streamProvider to be able to update my UI.
So I did listen to my stream in a streamProvider as the below:

//every scenario has a unique key that is used in this map as the key:
Map<String, StreamController<Uint8List>> scenarioControllers = {};

final streamProvider = StreamProvider.family<MyObject, String>((ref, key) async* {
     //
     debugPrint("program comes here"); //(A)
     //
     scenarioControllers[key].stream.listen((newData) async* {
     debugPrint("program does not call here");  //(B)
     MyObject obj = parseData(newData);
     yield obj;
    });
});

//socket-receiver: (C)
var newData = Uint8List.view(...);
scenarioControllers.update(key, (streamController) {
     streamController.sink.add(newData);
     return streamController;
}, ifAbsent() {
     var streamController = StreamController<Uint8List>();
     streamController.sink.add(newData);
     return streamController;
});

//UI - build method :
ref.watch(streamProvider(key)).when(
    data: (data) => widget(data),
    loading: () => waitWidget(),
   error: (e, stk) => errorWidget(),
);

Status:
Section (C) is called when I receive a new data from server.
Line (A) is called when streamProvider is called.
But Line (B) is never called and therefore streamProvider can not be updated from stream.listen!

I expect that execution of section (C) results in (B) is called too and therefore my streamProvider to be updated.
But why Section (B) is not called at all?

[AhmedLSayed9]

This part is not correct, you're using yield inside the listener (Also not disposing that listener is another thing):

 scenarioControllers[key].stream.listen((newData) async* {
 debugPrint("program does not call here");  //(B)
 MyObject obj = parseData(newData);
 yield obj;
});

Instead you can do:

await for (final newData in scenarioControllers[key].stream) {
   debugPrint("program does not call here");  //(B)
   MyObject obj = parseData(newData);
   yield obj;
}