subscribeToSSE method

Stream<SSEResponse> subscribeToSSE(
  1. String connectionId,
  2. SSERequest request, {
  3. dynamic fromJson(
    1. dynamic
    )?,
})

Implementation

Stream<SSEResponse> subscribeToSSE(String connectionId, SSERequest request,
    {Function(dynamic)? fromJson}) {
  if (_connections.containsKey(connectionId)) {
    return _connections[connectionId]!.stream;
  }

  final connection = _SSEConnection(request, fromJson);
  _connections[connectionId] = connection;
  return connection.stream;
}