flutter_stream_listener 1.0.0

Flutter package the helps manage streams and subscriptions. Built in order to reduce the complexity of having to manually subscribe to streams and cancel subscriptions.

example/lib/main.dart

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

void main() => runApp(MyApp());

/// Example StreamListener Flutter App
class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      home: MyHomePage(),
    );
  }
}

/// StatefulWidget which illustrates how to use [StreamListener].
class MyHomePage extends StatefulWidget {
  @override
  State<MyHomePage> createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  int _data = 0;

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('StreamListener Example'),
      ),
      body: StreamListener(
        stream: Stream.periodic(Duration(seconds: 1), (x) => x + 1).take(10),
        onData: (data) => setState(() {
          _data = data;
        }),
        onError: (error, stackTrace) => print(
          'onError $error, $stackTrace',
        ),
        onDone: () => print('onDone'),
        child: Center(
          child: Text('Stream Emitted $_data'),
        ),
      ),
    );
  }
}