Ну, на самом деле можно же ассоциировать реквест с таймаутом и отстреливать протухшие ещё до реквеста

Ну, на самом деле можно же ассоциировать реквест с таймаутом и отстреливать протухшие ещё до реквеста

Да, можно сделать свою обертку в качестве костыля

а где такие вещи из коробки есть?

https://akka.io/blog/news/2017/12/01/akka-http-10.0.11-released Http Client Pool Infrastructure Rewrite

Чат а какой хттп клиент сейчас нужно использовать в продакшене. Требования: нормальная конфигурация конеекшен пулинга по хостам и высокая производительность (1к рпс). Раньше пользовал спрей, но летне мейнтейнится, да апи у него так себе.

можно использовать низкоуровневые апи в акка хттп, но толку тогда? раз придётся всё равно свой пул руками писать

Мне надо было врапнуть Behavior[A] со следующими требованиями: 1. В результате должен быть Behavior[A] 2. Имея функцию f: A => IdentityKey, для каждого сообщения A нужно создавать/хранить инстанс Behavior[A] и роутить на него. 3. Убивать инстанс Behavior[A] если в течении idleTimeout не приходило сообщений. Получается что раньше бы я на скорую руку создал актор в котором бы в receive просто обрабатывал либо HandleTimeout и убивал бы воркера либо бы все остальное считал A и роутил на воркера Тут получилось надо сделать внутреннего актора с протоколом sealed abstract class InnerMessage[K, A] object InnerMessage { final case class HandleMessage[K, A](a: A) extends InnerMessage[K, A] final case class HandleIdleTimeout[K, A](key: K) extends InnerMessage[K, A] } И его врапнуть уже в актор с протоколом A, форвардя все A превращая их в HandleMessage. В вообщем стало лучше и меньше возможностей наговнокодить, прощай Any => Unit :)

да это всё днище. Хочется просто флажочек в конфиге иметь, а не вот это вот

ТЕОРИЯ КОТЕГОРИЙ УБИВАЕТ

cocancer

а скаланы еще вопрос, вот есть у меня стрим, на входе A на выходе B, и я хочу этот стрим сконвертить в Task[A => List[B]] или Future, как такое сделать?)

а скаланы еще вопрос, вот есть у меня стрим, на входе A на выходе B, и я хочу этот стрим сконвертить в Task[A => List[B]] или Future, как такое сделать?)

наверное, ты имел в виду A => Task[List[B]]?

внутри таска будет функция с эвэйтом?

def convert[Flow[_, _], A, B](f: Flow[A, B]): Task[A => List[B]] = Task.raiseError(new TrololoException)

откуда у вас мои исходники?

значит не любой

https://gist.github.com/Odomontois/699cd9ae7a14096a73da893e2c5a54c3

просто у меня мысли такие, что source: A, sink: B, и потом у этого стрима хочу сделать collect List[B] и превратить в Task[A => List[B]]

или Await

возвращаясь ко вчерашнему вопросу, нельзя имея A => Task[B] получить Task[A => B]

это утверждение?

А вот мне вчера подсказали

А как можно в Скала Макро проверить тип (TypeTree) на соответствие ограничению (что он наследует определенный родительский класс)?

на самом деле есть несколько комбинаций, превращающих F[G[A]] в G[F[A]]

В котах есть?

рефлект?

В котах есть?

https://oss.sonatype.org/service/local/repositories/snapshots/archive/org/scalaz/scalaz_2.12/7.3.0-SNAPSHOT/scalaz_2.12-7.3.0-SNAPSHOT-javadoc.jar/!/scalaz/Distributive.html

https://oss.sonatype.org/service/local/repositories/snapshots/archive/org/scalaz/scalaz_2.12/7.3.0-SNAPSHOT/scalaz_2.12-7.3.0-SNAPSHOT-javadoc.jar/!/scalaz/Distributive.html

торреборе что ли

Почитал. Для Таска дистрибутив не напишешь, так же как и для функции траверс. Задача @nikitamatveenko не решается