client_sse 1.0.0-beta

Dart package to help consume SSE API. It consumes server sent events by returning parsed model of the event, id, and the data

example/main.dart

import 'package:client_sse/constants/sse_request_type_enum.dart';
import 'package:client_sse/flutter_client_sse.dart';

void main() {
  ///GET REQUEST
  SSEClient.subscribeToSSE(
      method: SSERequestType.GET,
      url: 'http://localhost:3000/sse',
      header: {
        "Cookie":
            'jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6InRlc3QiLCJpYXQiOjE2NDMyMTAyMzEsImV4cCI6MTY0MzgxNTAzMX0.U0aCAM2fKE1OVnGFbgAU_UVBvNwOMMquvPY8QaLD138; Path=/; Expires=Wed, 02 Feb 2022 15:17:11 GMT; HttpOnly; SameSite=Strict',
        "Accept": "text/event-stream",
        "Cache-Control": "no-cache",
      }).listen(
    (event) {
      print('Id: ' + (event.id ?? ""));
      print('Event: ' + (event.event ?? ""));
      print('Data: ' + (event.data ?? ""));
    },
  );

  ///POST REQUEST
  SSEClient.subscribeToSSE(
      method: SSERequestType.POST,
      url:
          'http://192.168.1.2:3000/api/activity-stream?historySnapshot=FIVE_MINUTE',
      header: {
        "Cookie":
            'jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6InRlc3QiLCJpYXQiOjE2NDMyMTAyMzEsImV4cCI6MTY0MzgxNTAzMX0.U0aCAM2fKE1OVnGFbgAU_UVBvNwOMMquvPY8QaLD138; Path=/; Expires=Wed, 02 Feb 2022 15:17:11 GMT; HttpOnly; SameSite=Strict',
        "Accept": "text/event-stream",
        "Cache-Control": "no-cache",
      },
      body: {
        "name": "Hello",
        "customerInfo": {"age": 25, "height": 168}
      }).listen(
    (event) {
      print('Id: ' + event.id!);
      print('Event: ' + event.event!);
      print('Data: ' + event.data!);
    },
  );
}