Flutter Bloc初始事件无法返回状态问题及路由实现咨询

刚接触Flutter Bloc，为启动页（Splash Screen）添加了用户登录状态检查逻辑。已确认listenAuthState方法被触发，但无法获取返回状态。现附上SplashBloc及UI相关代码，询问当前状态发射方式是否正确，以及如何在Bloc中实现基于状态的路由跳转。

Bloc 代码 #

class SplashBloc extends Bloc<SplashEvent, SplashState> {
  final supabaseClient = Supabase.instance.client;
  Session? userSession;
  SplashBloc() : super(SplashInitialState()) {
    on<SplashInitialEvent>(listenAuthState);
  }

  StreamSubscription<AuthState> listenAuthState(
      SplashInitialEvent event, Emitter<SplashState> emit) {
    debugPrint("Initial Call Triggered"); // this line prints on initial
    return supabaseClient.auth.onAuthStateChange.listen((data) {
      final Session? session = data.session;
      final AuthChangeEvent event = data.event;
      switch (event) {
        case AuthChangeEvent.passwordRecovery:
          break;
        case AuthChangeEvent.signedIn:
          return emit(SignedInState());
        case AuthChangeEvent.signedOut:
          return emit(NotSignedInState()); // trying to emit this event.
        case AuthChangeEvent.tokenRefreshed:
          break;
        case AuthChangeEvent.userUpdated:
          break;
        case AuthChangeEvent.userDeleted:
          break;
        case AuthChangeEvent.mfaChallengeVerified:
          break;
      }
    });
  }
}

UI 代码 #

return BlocProvider<SplashBloc>(
  create: (context) => SplashBloc()..add(SplashInitialEvent()),
  child: Scaffold(
    body: Builder(
      builder: (context) {
        return BlocListener(
          bloc: BlocProvider.of<SplashBloc>(context),
          listener: (context, state) {
            if (state is NotSignedInState) {
              debugPrint('state is notsignedstate');
              context.go('/onboarding');
            } else {
              context.go('/home');
            }
          },
          child: Center(
            child: Lottie.asset(splashLottied),
          ),
        );
      }
    ),
  ),
);

问题分析与解决 #

1. 状态发射问题 #

你的状态发射逻辑存在两处关键问题：

• 回调内直接return：在onAuthStateChange的监听回调中使用return emit(...)会直接终止回调，可能导致StreamSubscription管理异常，应去掉return直接调用emit()。
• 缺少初始会话检查：onAuthStateChange仅在状态变更时触发，APP启动时若用户本来处于未登录状态，不会触发signedOut事件，因此需要在Bloc初始化时主动检查当前会话。

修改后的Bloc代码：

class SplashBloc extends Bloc<SplashEvent, SplashState> {
  final supabaseClient = Supabase.instance.client;
  Session? userSession;
  StreamSubscription<AuthState>? _authSubscription;

  SplashBloc() : super(SplashInitialState()) {
    on<SplashInitialEvent>(listenAuthState);
    // 初始化时主动检查当前登录状态
    _checkInitialSession();
  }

  void _checkInitialSession() {
    final currentSession = supabaseClient.auth.currentSession;
    if (currentSession != null) {
      emit(SignedInState());
    } else {
      emit(NotSignedInState());
    }
  }

  StreamSubscription<AuthState> listenAuthState(
      SplashInitialEvent event, Emitter<SplashState> emit) {
    debugPrint("Initial Call Triggered");
    _authSubscription = supabaseClient.auth.onAuthStateChange.listen((data) {
      final AuthChangeEvent authEvent = data.event;
      switch (authEvent) {
        case AuthChangeEvent.signedIn:
          emit(SignedInState());
          break;
        case AuthChangeEvent.signedOut:
          emit(NotSignedInState());
          break;
        // 其他事件按需处理
        default:
          break;
      }
    });
    return _authSubscription!;
  }

  @override
  Future<void> close() {
    _authSubscription?.cancel();
    return super.close();
  }
}

2. 基于状态的路由跳转 #

你的UI层使用BlocListener的思路正确，但需要优化重复跳转问题：

• 避免重复跳转：当前代码只要状态变更就会执行跳转，即使是相同状态重复发射也会触发，需添加路由判断，仅在目标路由与当前路由不一致时跳转。
• 简化Bloc获取方式：用context.read<SplashBloc>()替代BlocProvider.of<SplashBloc>(context)，代码更简洁。

修改后的UI代码：

return BlocProvider<SplashBloc>(
  create: (context) => SplashBloc(),
  child: Scaffold(
    body: BlocListener<SplashBloc, SplashState>(
      listener: (context, state) {
        // 跳过初始状态，仅处理登录/未登录状态
        if (state is! SplashInitialState) {
          final currentRoute = GoRouterState.of(context).fullPath;
          if (state is NotSignedInState && currentRoute != '/onboarding') {
            debugPrint('state is notsignedstate');
            context.go('/onboarding');
          } else if (state is SignedInState && currentRoute != '/home') {
            context.go('/home');
          }
        }
      },
      child: const Center(
        child: Lottie.asset(splashLottied),
      ),
    ),
  ),
);

额外建议 #

• 确保SplashInitialState、SignedInState、NotSignedInState均正确继承自SplashState抽象类。
• 在Bloc的close方法中取消StreamSubscription，避免内存泄漏。
• 若使用GoRouter，建议将路由逻辑封装到独立的导航服务中，让Bloc不直接依赖路由，保持业务逻辑与UI层解耦。

内容的提问来源于stack exchange，提问作者Febin Johnson