如何从StreamBuilder获取StreamSubscription

import 'dart:async';
import 'package:flutter/material.dart';

class MyWidget extends StatefulWidget {
  @override
  _MyWidgetState createState() => _MyWidgetState();
}

class _MyWidgetState extends State<MyWidget> {
  Stream<int> _stream;
  StreamSubscription<int> _subscription;

  @override
  void initState() {
    super.initState();
    // 创建一个Stream并订阅
    _stream = _createStream();
    _subscription = _stream.listen((data) {
      // 在有新的数据到达时执行操作
      print('New data: $data');
    });
  }

  @override
  void dispose() {
    // 取消订阅
    _subscription.cancel();
    super.dispose();
  }

  Stream<int> _createStream() {
    // 创建一个简单的计时器Stream作为示例
    return Stream.periodic(Duration(seconds: 1), (count) => count);
  }

  @override
  Widget build(BuildContext context) {
    return StreamBuilder<int>(
      stream: _stream,
      builder: (context, snapshot) {
        if (snapshot.hasData) {
          // 如果有新的数据到达，构建相应的UI
          return Text('Data: ${snapshot.data}');
        } else {
          // 如果没有新的数据，显示加载中的UI
          return CircularProgressIndicator();
        }
      },
    );
  }
}