KS
Да, они в 3 сделали авто yield через сколько-то там операций плюс кажется поменяли пул на форкжоин
Size: a a a
2021 January 17
ЮБ
Всё так
λ
Какие гарантии есть в ce2 после вызова unsafeRunSync относительно исполнения файберов, если мейн ИО завершилось?
если сделать unsafeRunSync, и при этом мейн тред продолжит работать, то файберы рано или поздно отработают.
λ
Если main IO завершится, то может случится дедлок
λ
не знаю починили ли это
Oℕ
Какие гарантии есть в ce2 после вызова unsafeRunSync относительно исполнения файберов, если мейн ИО завершилось?
никаких же
λ
Ну там по факту семантика не должна была изменится
Из-за того, что send теперь делается внутри файберов, а их исполнение может быть отложено, то можно успеть закрыть ресурс продьюсера раньше вызова сенд. Так и происходило в тестах. На проде такой ресурс долгоживущий и завершается вместе с приложением.
ЮБ
Из-за того, что send теперь делается внутри файберов, а их исполнение может быть отложено, то можно успеть закрыть ресурс продьюсера раньше вызова сенд. Так и происходило в тестах. На проде такой ресурс долгоживущий и завершается вместе с приложением.
Ну вообще и раньше такое могло произойти.
λ
Ну вообще и раньше такое могло произойти.
Нет, раньше если внутри use вызывался producer.send, то отправлялось точно (клалось в буфер)
λ
А щас может создасться файбер, но не выполниться
λ
Зафейленный тест как раз и показал разницу
ЮБ
Нет, раньше если внутри use вызывался producer.send, то отправлялось точно (клалось в буфер)
Положить в буфер != Отправлялось
λ
В данном случае это неважно. Тут проблема утечки ресурса
ЮБ
Колбэк, который резолвит внутренний F, не вызовется, если ресурс закроется
ЮБ
Я думаю, что и в старой версии можно было добиться такого поведения
ЮБ
Просто, наверное, вам везло
λ
Колбэк, который резолвит внутренний F, не вызовется, если ресурс закроется
Колбэк деферред заполняет. А он мне не нужен
2021 January 18
R
если я в akka-http в сделаю complete(someSource), где someSource типа Source[.., ..], произойдёт ли backpressure?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
AD
RAFIZ
если я в akka-http в сделаю complete(someSource), где someSource типа Source[.., ..], произойдёт ли backpressure?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
Там в доке написано про интеграцию со стримами об этом
e
RAFIZ
если я в akka-http в сделаю complete(someSource), где someSource типа Source[.., ..], произойдёт ли backpressure?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
если веб-клиент, который сделал запрос на получение этого someSource - медленный - то это вынудит сервер выдавать результат помедленнее и отправить по сети все без потерь для клиента?
Поставьте перед диким интернетом реверс прокси, например nginx .