toStreamFromJson static method

Stream<EventData> toStreamFromJson(
  1. String eventType,
  2. dynamic data, {
  3. UuidV4? uuid,
  4. Map<String, dynamic> metadata = const <String, dynamic>{},
})

Create Stream from single event with json data

Implementation

static Stream<EventData> toStreamFromJson(
  String eventType,
  dynamic data, {
  UuidV4? uuid,
  Map<String, dynamic> metadata = const <String, dynamic>{},
}) {
  return Stream.fromIterable([
    EventData(
      type: eventType,
      data: utf8.encode(jsonEncode(data)),
      metadata: utf8.encode(jsonEncode(data)),
      contentType: ContentTypes.ApplicationJson,
      uuid: uuid?.value.uuid ?? UuidV4.newUuid().value.uuid,
    )
  ]);
}