Size: a a a

Scala User Group

2020 June 04

IK

Ivan Klass in Scala User Group
Переслано от Ivan Klass
вместо "4" выведет
java.lang.BootstrapMethodError: call site initialization exception
 at java.lang.invoke.CallSite.makeSite(CallSite.java:341)
 at java.lang.invoke.MethodHandleNatives.linkCallSiteImpl(MethodHandleNatives.java:307)
 at java.lang.invoke.MethodHandleNatives.linkCallSite(MethodHandleNatives.java:297)
 at Baz.forInt(<pastie>:28)
 ... 28 elided
Caused by: java.lang.invoke.LambdaConversionException: Functional interface java.lang.Object is not an interface
 at java.lang.invoke.AbstractValidatingLambdaMetafactory.<init>(AbstractValidatingLambdaMetafactory.java:145)
 at java.lang.invoke.InnerClassLambdaMetafactory.<init>(InnerClassLambdaMetafactory.java:155)
 at java.lang.invoke.LambdaMetafactory.altMetafactory(LambdaMetafactory.java:466)
 at java.lang.invoke.CallSite.makeSite(CallSite.java:310)
 ... 31 more
источник

IK

Ivan Klass in Scala User Group
Переслано от Ivan Klass
примечательно, что если в Baz явно указать в возвращаемом типе Bar вместо Typeclass (т.е. override def forInt: Bar[Int] = _.toString) баг не триггернётся
источник

IK

Ivan Klass in Scala User Group
источник

λ

λoλdog in Scala User Group
Код на скала, но баг джава компилятора?
источник

λ

λoλdog in Scala User Group
А, нужно ссылку посмотреть
источник

PL

Pavel L in Scala User Group
Всем привет!

Использую akka-http для стриминга real-time данных пользователя по вебсокету и столкнулся с такой проблемой, что после закрытия вебсокета клиентом - нет гарантий, что мой стрим данных тоже закроется.    

Cудя по документации, это мог бы гарантировать как раз таки fromSinkAndSourceCoupled - https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSourceCoupled.html

В моем случае я использую Kafka consumer в качестве Source-а сообщений пользователю и ожидаю, что как только пользователь закроет соединение - Source consumer-а мог бы закрыться.

extractUpgradeToWebSocket { upgrade =>
 complete {
   upgrade.handleMessages(
     Flow.fromSinkAndSourceCoupled(ignoreWsIncomingMessagesSink, streamUserNotificationsSource)
   )
 }
}


К сожалению, так не происходит и ничего лучше пока кроме как повесить listener с помощью на watchTermination и там уже принудительно закрывать Source дальше - я не нашел

up
grade.handleMessages(
 Flow.fromSinkAndSourceCoupled(ignoreWsIncomingMessagesSink, streamUserNotificationsSource)
).watchTermination() { (mat, fut) =>
 fut.onComplete { _ =>    
   listener.unsubscribe(request.userId)
 }
 mat
}

Было бы здорово узнать если кто-то уже сталкивался / наблюдал похожее 🙂
источник

P

Python in Scala User Group
Pavel L
Всем привет!

Использую akka-http для стриминга real-time данных пользователя по вебсокету и столкнулся с такой проблемой, что после закрытия вебсокета клиентом - нет гарантий, что мой стрим данных тоже закроется.    

Cудя по документации, это мог бы гарантировать как раз таки fromSinkAndSourceCoupled - https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSourceCoupled.html

В моем случае я использую Kafka consumer в качестве Source-а сообщений пользователю и ожидаю, что как только пользователь закроет соединение - Source consumer-а мог бы закрыться.

extractUpgradeToWebSocket { upgrade =>
 complete {
   upgrade.handleMessages(
     Flow.fromSinkAndSourceCoupled(ignoreWsIncomingMessagesSink, streamUserNotificationsSource)
   )
 }
}


К сожалению, так не происходит и ничего лучше пока кроме как повесить listener с помощью на watchTermination и там уже принудительно закрывать Source дальше - я не нашел

up
grade.handleMessages(
 Flow.fromSinkAndSourceCoupled(ignoreWsIncomingMessagesSink, streamUserNotificationsSource)
).watchTermination() { (mat, fut) =>
 fut.onComplete { _ =>    
   listener.unsubscribe(request.userId)
 }
 mat
}

Было бы здорово узнать если кто-то уже сталкивался / наблюдал похожее 🙂
Раз watchTermination сработал, значит Flow остановился. Если бы не было coupled, то он, наверное, так и остался бы висеть...

Надо смотреть на этот Source. Что там внутри? Если его без WebSocket'а запустить и закрыть, то этот unsubscribe срабатывает?
источник

RI

Rustam Iksanov in Scala User Group
А есть свежее сравнение фреймворков для доступа к БД? Самое свежее, до сих пор сравнение Адама Варски.
источник

λ

λoλcat in Scala User Group
Rustam Iksanov
А есть свежее сравнение фреймворков для доступа к БД? Самое свежее, до сих пор сравнение Адама Варски.
С тех пор ничего не изменилось
источник

P

Python in Scala User Group
Помню на днях в cats добавляли что-то, что позволяет сделать xxx flatMap (_(parameter)) более красиво. Или у меня ложная память?
источник

AS

Andrey Sugak in Scala User Group
Python
Помню на днях в cats добавляли что-то, что позволяет сделать xxx flatMap (_(parameter)) более красиво. Или у меня ложная память?
mapApply
источник

P

Python in Scala User Group
Andrey Sugak
mapApply
🙇‍♂️
источник

D

Daniel in Scala User Group
Andrey Sugak
mapApply
так тут флэтмап просят
источник

AS

Andrey Sugak in Scala User Group
Daniel
так тут флэтмап просят
Для флэтмапа вроде такого синтакиса в котах нет.
источник

D

Daniel in Scala User Group
Andrey Sugak
Для флэтмапа вроде такого синтакиса в котах нет.
ну
источник

Oℕ

Oleg ℕizhnik in Scala User Group
Да, тоже изредка хотел такой синтаксис
источник

Oℕ

Oleg ℕizhnik in Scala User Group
но каждый раз оказывалось, что я просто ленюсь фор написать
источник
2020 June 05

S

SoulAwakening in Scala User Group
Всем привет! Начал изучать java, интересно направление BigData. Можете подсказать с чего начинать путь в Scala?
источник

AT

Aλeksei Tereχin in Scala User Group
С чтения описания этого чата
источник

VS

Valeriy Shinkevich in Scala User Group
SoulAwakening
Всем привет! Начал изучать java, интересно направление BigData. Можете подсказать с чего начинать путь в Scala?
а за бигдатой лучше сюда https://t.me/hadoopusers
источник