Я новичок в скале. В настоящее время для создания остальных API я использую спрей. Теперь я хочу использовать API с другого сервера. Я вызываю этот API при каждом нажатии клавиши из пользовательского интерфейса. Я прерываю запрос с помощью AbortController, если пользователь продолжает печатать, а предыдущий запрос находится в состоянии ожидания. Чтобы выполнить другой запрос к серверу, я использую спрей-клиент. Что-то вроде этого:
def completeService(completeRequest: CompleteRequest): Future[HttpResponse] = {
val pipeline: HttpRequest => Future[HttpResponse] = sendReceive ~> unmarshal[HttpResponse]
val response: Future[HttpResponse] = pipeline(Post(someremoteUrl.concat("complete"), completeRequest)
~> addHeader("demo", "test"))
response
}
Я могу получить доступ, используя этот код выше. И получаю ожидаемый ответ. Но дело требует времени. Он создает новое TCP-соединение и связывается с хостом, обращается к API, дает ответ, а затем разрывает соединение. Здесь при завершении он иногда простаивает и не принимает новое соединение.
Есть ли альтернативный способ сделать это?
