Size: a a a

Scala User Group

2020 October 13

E

Elijah in Scala User Group
просто пока не привык сниппеты туда ложить
источник

Oℕ

Oleg ℕizhnik in Scala User Group
вылаживать
источник

GP

Grigory Pomadchin in Scala User Group
лудить сниппеты
источник

Oℕ

Oleg ℕizhnik in Scala User Group
Ну я в этих кукареках никогда не участвовал
источник

Oℕ

Oleg ℕizhnik in Scala User Group
И не видел никого, кто участвовал
источник

K

Kai in Scala User Group
Oleg ℕizhnik
Маквайр - это инфериор технология по сравнению с имплиситами, по сравнению с ним всё, что-угодно будет лучше
Ну, он еще и тормозит. А еще его юзают
источник

ИМ

Иван Малышев... in Scala User Group
Привет. Вопрос про ZIO Streams
Я правильно понимаю, что в их модели нет никакого супервайзера над ошибками, если таковая случилась — то весь стрим кладется, и данные, которые в него ушли, но еще не были обработаны, теряются?

Написал такой пример.
https://scastie.scala-lang.org/vagroz/d6M0zseVTya8mY3SkuLFvQ/5
В очереди лежат чиселки от 1 до 52, оттуда делается стрим с размерами чанков 8. Далее он прогоняется через ZTrancducer, который на числе, кратном 5 кидает ошибку, а остальные числа просто распечатывает. В конце тупо runDrain , и на этом результирующем эффекте retry.

Получаю вывод:
Data: 1
Data: 2
Data: 3
Data: 4
Data: 9
Data: 17 [...]

Получается, в transducer попал первый чанк 1-8, 1-4 он вывел, на 5 упал, 6-8 птерялись. Стрим завершился, сработал retry, из очереди вытянулся следующий чанк 9-16, 9 распечатал, на 10 упал, 11-16 потерялись. И так далее

Вопрос: можно ли, рассматривая transducer как черный ящик, вывести все числа от 1 до 52 (кроме кратных 5)?
источник

K

Kai in Scala User Group
ща сделаю бенчмарк и узнаем ух
источник

K

Kai in Scala User Group
Иван Малышев
Привет. Вопрос про ZIO Streams
Я правильно понимаю, что в их модели нет никакого супервайзера над ошибками, если таковая случилась — то весь стрим кладется, и данные, которые в него ушли, но еще не были обработаны, теряются?

Написал такой пример.
https://scastie.scala-lang.org/vagroz/d6M0zseVTya8mY3SkuLFvQ/5
В очереди лежат чиселки от 1 до 52, оттуда делается стрим с размерами чанков 8. Далее он прогоняется через ZTrancducer, который на числе, кратном 5 кидает ошибку, а остальные числа просто распечатывает. В конце тупо runDrain , и на этом результирующем эффекте retry.

Получаю вывод:
Data: 1
Data: 2
Data: 3
Data: 4
Data: 9
Data: 17 [...]

Получается, в transducer попал первый чанк 1-8, 1-4 он вывел, на 5 упал, 6-8 птерялись. Стрим завершился, сработал retry, из очереди вытянулся следующий чанк 9-16, 9 распечатал, на 10 упал, 11-16 потерялись. И так далее

Вопрос: можно ли, рассматривая transducer как черный ящик, вывести все числа от 1 до 52 (кроме кратных 5)?
А разве там нет .catchAll и .sandbox?
источник

ИМ

Иван Малышев... in Scala User Group
Kai
А разве там нет .catchAll и .sandbox?
sandbox нет, catchAll требует Throwable => ZStream, запихнул в нее исходный же стрим, че т все зависло. Попробую ее еще повертеть, спасибо
источник

BT

Boris T in Scala User Group
Oleg ℕizhnik
Маквайр - это инфериор технология по сравнению с имплиситами, по сравнению с ним всё, что-угодно будет лучше
ого. а что не так?
источник

Oℕ

Oleg ℕizhnik in Scala User Group
Boris T
ого. а что не так?
а что так
источник

BT

Boris T in Scala User Group
а я не знаю, не использовал
источник

BT

Boris T in Scala User Group
но думал
источник

Oℕ

Oleg ℕizhnik in Scala User Group
а зачем
источник

VH

Valentyn Hetman in Scala User Group
А много тут людей java хоть знают?
источник

Б

Берял in Scala User Group
Valentyn Hetman
А много тут людей java хоть знают?
а нужно?
источник

VH

Valentyn Hetman in Scala User Group
Берял
а нужно?
Вот интересно а нужно ли
источник

VH

Valentyn Hetman in Scala User Group
Берял
а нужно?
Выглядит после джавы прикольно
источник

VH

Valentyn Hetman in Scala User Group
Но одновременно оттплкивает
источник