SseChannel

interface SseChannel {
  UUID getId()
  Class<?> getSourceType()
  void listenWhile(Predicate<SseSource> listener)
  void fire(SseSource source)
  void close()
  void awaitClose()
}