вместо "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

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

Код на скала, но баг джава компилятора?

А, нужно ссылку посмотреть

Всем привет!

Использую 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
}

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

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

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

Раз watchTermination сработал, значит Flow остановился. Если бы не было coupled, то он, наверное, так и остался бы висеть...

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

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

С тех пор ничего не изменилось

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

🙇‍♂️

так тут флэтмап просят

Для флэтмапа вроде такого синтакиса в котах нет.

ну

Да, тоже изредка хотел такой синтаксис

но каждый раз оказывалось, что я просто ленюсь фор написать

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

С чтения описания этого чата

а за бигдатой лучше сюда https://t.me/hadoopusers