10 сек эмонирует данные (слушает сокет и отдаёт данные через callback) (дальше эти данные анализируются в функциях, принимаются решения и дергается внешнее API...)
Как его грамотно вплести в pure functional программу, сделать источником ?
На ум приходит обернуть его в актор и с помощью Akka Streams преобразовать в источник Source.actorRef()
Есть ли более простое и элегантное решение, чтоб не тащить AkkaStreams ?
def read: F[A]
Обсуждают сегодня