flutter_sse_flow 0.1.0

A robust Server-Sent Events (SSE) client for Flutter, featuring automatic reconnections, stream parsing, and OIDC automated publishing.

example/lib/main.dart

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

void main() {
  runApp(const MyApp());
}

class MyApp extends StatelessWidget {
  const MyApp({super.key});

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter SSE Flow Demo',
      theme: ThemeData(primarySwatch: Colors.blue),
      home: const SSEHomeScreen(),
    );
  }
}

class SSEHomeScreen extends StatefulWidget {
  const SSEHomeScreen({super.key});

  @override
  State<SSEHomeScreen> createState() => _SSEHomeScreenState();
}

class _SSEHomeScreenState extends State<SSEHomeScreen> {
  final FlutterSseFlow _sseClient = FlutterSseFlow();
  final List<SSEModel> _events = <SSEModel>[];

  @override
  void initState() {
    super.initState();
    _sseClient.sseStream.listen((SSEModel event) {
      setState(() {
        _events.insert(0, event);
      });
    });
    _sseClient.statusStream.listen((SseConnectionStatus status) {
      setState(() {});
    });
  }

  void _connect() {
    // Example URL. Replace with a real SSE endpoint to test.
    _sseClient.connect(
      url: 'https://api.example.com/v1/stream',
      headers: () => <String, String>{
        'Authorization': 'Bearer YOUR_TOKEN_HERE',
      },
    );
  }

  void _disconnect() {
    _sseClient.disconnect();
    setState(() {});
  }

  @override
  Widget build(BuildContext context) {
    final bool isActive =
        _sseClient.status != SseConnectionStatus.idle &&
        _sseClient.status != SseConnectionStatus.disconnected &&
        _sseClient.status != SseConnectionStatus.unauthorized;

    return Scaffold(
      appBar: AppBar(title: Text('SSE Flow (${_sseClient.status.name})')),
      body: Column(
        children: <Widget>[
          Padding(
            padding: const EdgeInsets.all(8.0),
            child: Row(
              mainAxisAlignment: MainAxisAlignment.spaceEvenly,
              children: <Widget>[
                ElevatedButton(
                  onPressed: isActive ? null : _connect,
                  child: const Text('Connect'),
                ),
                ElevatedButton(
                  onPressed: isActive ? _disconnect : null,
                  child: const Text('Disconnect'),
                ),
              ],
            ),
          ),
          Expanded(
            child: ListView.builder(
              itemCount: _events.length,
              itemBuilder: (BuildContext context, int index) {
                final SSEModel event = _events[index];
                return ListTile(
                  title: Text(
                    event.event.isEmpty ? 'Unknown Event' : event.event,
                  ),
                  subtitle: Text(event.data.isEmpty ? 'No data' : event.data),
                );
              },
            ),
          ),
        ],
      ),
    );
  }

  @override
  void dispose() {
    _sseClient.dispose();
    super.dispose();
  }
}