EventSource

fun EventSource(requestSupplier: suspend (Headers) -> Request, retryTime: Duration = retryTimeDefault, eventTimeout: Duration? = eventTimeoutDefault, eventTimeoutCheckInterval: Duration = eventTimeoutCheckIntervalDefault, logger: Logger = LoggerFactory.getLogger(EventSource::class.java))