mercure_client 1.0.0

mercure_client: ^1.0.0 copied to clipboard

example/mercure_client_example.dart

import 'dart:convert';

import 'package:mercure_client/mercure_client.dart';

Future<void> main() async {
  final books = <Book>[];

  final mercure = Mercure(
    url: 'http://example.com/.well-known/mercure', // your mercure hub url
    topics: ['/books/{id}'], // your mercure topic
    token: 'your_jwt_token', // Bearer authorization
    lastEventId: 'last_event_id', // in case your stored last recieved event
  );

  /// Subscribe to mercure hub
  await for (final event in mercure) {
    books.add(Book.fromJson(json.decode(event.data) as Map<String, dynamic>));
  }
}

class Book {
  Book._(this.id, this.title);

  factory Book.fromJson(Map<String, dynamic> json) {
    return Book._(
      json['id'] as int,
      json['title'] as String,
    );
  }

  final int id;
  final String title;

  Map<String, dynamic> toJson() => <String, dynamic>{'id': id, 'title': title};
}