Stream on sembast database doesn't initialize or can be listen to

[josh4500]

_listener = 
        .messageStore
        .query(finder: finder)
        .onSnapshots(await _db)
        .listen(
      (snapshots) {
        context.read<ChatBloc>().add(AddNewMessagesList(
            messages: snapshots.map((e) => Message.fromMap(e.value)).toList()));
        Future.delayed(
          const Duration(milliseconds: 10),
          () {
            _messageScrollController.animateTo(
              0.0,
              duration: const Duration(milliseconds: 300),
              curve: Curves.fastOutSlowIn,
            );
          },
        );
      },
    );

Listener doesn't initialize and throws error when trying to close the stream