Flutter Bloc中如何从流发射状态？认证状态监听疑问

报错原因分析 #

你遇到的两个报错本质都是上下文不符导致的：

• emit仅能在Bloc的事件处理回调（on<Event>闭包）或mapEventToState异步生成器函数内调用，而Supabase的listen回调是普通同步函数，不在有效上下文范围内，因此直接调用emit会报错。
• yield只能在标记为async*/sync*的生成器函数中使用，listen回调不属于这类函数，自然无法使用yield。

另外你的代码混合了Bloc新旧API（on<Event>和mapEventToState共存），这也是不规范的写法，建议统一使用官方推荐的新API。

正确实现方案（新API推荐） #

1. 补充定义状态变化事件

abstract class SplashEvent {}

class SplashInitialEvent extends SplashEvent {}

// 新增事件，用于传递Supabase的认证状态变更
class AuthStateChangedEvent extends SplashEvent {
  final AuthState authState;

  AuthStateChangedEvent(this.authState);
}

2. 重构SplashBloc代码

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

  SplashBloc() : super(SplashInitialState()) {
    // 绑定事件处理逻辑
    on<SplashInitialEvent>(_handleInitialEvent);
    on<AuthStateChangedEvent>(_handleAuthStateChanged);
  }

  // 处理初始化事件，启动Supabase状态监听
  void _handleInitialEvent(SplashInitialEvent event, Emitter<SplashState> emit) {
    // 先取消旧订阅，避免内存泄漏
    _subscription?.cancel();
    
    // 监听认证状态变化，通过添加事件的方式触发状态更新
    _subscription = supabaseClient.auth.onAuthStateChange.listen((authState) {
      add(AuthStateChangedEvent(authState));
    });

    // 立即检查当前会话状态，同步初始状态
    final currentSession = supabaseClient.auth.currentSession;
    if (currentSession?.accessToken != null) {
      emit(SignedInState());
    } else {
      emit(NotSignedInState());
    }
  }

  // 处理认证状态变更事件，更新Bloc状态
  void _handleAuthStateChanged(AuthStateChangedEvent event, Emitter<SplashState> emit) {
    if (event.authState.session?.accessToken != null) {
      emit(SignedInState());
    } else {
      emit(NotSignedInState());
    }
  }

  // 关闭Bloc时取消订阅，释放资源
  @override
  Future<void> close() {
    _subscription?.cancel();
    return super.close();
  }
}

旧API实现方式（兼容旧代码，不推荐） #

如果需要基于mapEventToState实现，可以用await for监听流，确保在生成器函数内使用yield：

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

  SplashBloc() : super(SplashInitialState());

  @override
  Stream<SplashState> mapEventToState(SplashEvent event) async* {
    if (event is SplashInitialEvent) {
      _subscription?.cancel();
      
      // 同步初始会话状态
      final currentSession = supabaseClient.auth.currentSession;
      if (currentSession?.accessToken != null) {
        yield SignedInState();
      } else {
        yield NotSignedInState();
      }

      // 通过await for监听流，在生成器内安全使用yield
      await for (final authState in supabaseClient.auth.onAuthStateChange) {
        if (authState.session?.accessToken != null) {
          yield SignedInState();
        } else {
          yield NotSignedInState();
        }
      }
    }
  }

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

核心注意点 #

• 优先使用Bloc新API（on<Event>），逻辑更清晰，符合官方设计方向。
• 无论哪种实现，都必须在Bloc关闭时取消Supabase的流订阅，防止内存泄漏。

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