Flutter FutureBuilder と StreamBuilder

var controller = StreamController<int>();
var stream = controller.stream;

// ストリームを listen() しておくと、そのデータを受け取れる
var subscription = stream.listen((data) => print('listen=$data'),
    onError: (error) {
        //エラー処理
    },
    cancelOnError: false,
    onDone: () {
        //完了時に呼ばれる
    });

// ストリームにデータを流す
controller.sink.add(1);

// 1秒待機
await Future.delayed(Duration(second: 1));

// ストリームを閉じる
subscription.cancel();
controller.close();

FutureBuilder(
    future: Repository().fetch(),
    builder: (context, snapshot) {
        if (snapshot.connectionState == ConnectionState.done) {
            if (snaphost.hasError) {
                return // エラー表示のウィジェットを記述 
            }
            if (!snapshot.hasData) {
                return // データ無し表示のウィジェットを記述
            }
            // データ表示
            return Text('${snapshot.data}');
        } else {
            // 処理中の表示
            return const CircularProgressIndicator();
        }
    },
),

class Repository {
    Future<int> fetch() {
        return Future.delayed(Duration(second: 1).then((_) {
            return 1; 
        });
    }
}

child: Column(
    children: [
        FutureBuilder<PackageInfo>(
            future: PackageInfo.fromPlatform(),
            builder: (context, snapshot) {
                return Text('Ver. ${snapshot.data?.version ?? '-'}');
            },
        ),
    ]
)

StreamBuilder<int> (
    stream: logic.value,
    builder: (context, snapshot) {
        if (snaphost.connectionState == ConnectionState.done) {
            if (snapshot.hasError) {
                return ErrorWidget(snapshot.error);
            }
            if (!snapshot.hasData) {
                retrun Container();
            }
            return Text('${snapshot.data}');
        } else {
            return const CirculearProgressIndicator();
        }
    },
),