dart_http_sse 1.0.3

Flutter HTTP Server-Sent Events (SSE) client library for receive real-time updates from the server

example/main.dart

import 'dart:developer';

import 'package:dart_http_sse/client/sse_client.dart';
import 'package:dart_http_sse/model/sse_request.dart';
import 'package:dart_http_sse/model/sse_response.dart';
import 'package:flutter/material.dart';


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

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

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'SSE Client Example',
      theme: ThemeData(primarySwatch: Colors.blue),
      home: SSEPage(),
    );
  }
}

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

  @override
  SSEPageState createState() => SSEPageState();
}

class SSEPageState extends State<SSEPage> {
  late SSEClient _sseClient;
  late Stream<SSEResponse> _stream;
  final List<String> _messages = [];

  @override
  void initState() {
    super.initState();
    _sseClient = SSEClient();
    _connectToSSE();
  }

  void _connectToSSE() {
    final request = SSERequest(
      url: 'https://your-sse-server.com/events',
      onData: (response) {
        log("New SSE Event: ${response.data}");
      },
      onError: (error) {
        log("SSE Error: $error");
      },
      onDone: () {
        log("SSE Connection Closed");
      },
      retry: true,
    );

    _stream = _sseClient.connect('sse_connection1', request);

    _stream.listen(
      (event) {
        setState(() {
          _messages.add(event.data.toString());
        });
      },
      onError: (error) {
        log("Stream Error: $error");
      },
      onDone: () {
        log("Stream Closed");
      },
    );
  }

  @override
  void dispose() {
    _sseClient.close(connectionId: 'sse_connection');
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(title: Text('SSE Client Example')),
      body: ListView.builder(
        itemCount: _messages.length,
        itemBuilder: (context, index) {
          return ListTile(
            title: Text(_messages[index]),
          );
        },
      ),
    );
  }
}