SseSource

interface SseSource {
  void run(SseChannel channel)
  String getPayload()
  boolean isObservable(Class<?> type)
}