source
.fold(0l){ (count, byteString) => count + chan.write(byteString.asByteBuffer) }
.runWith(Sink.head)
.andThen { case _ => chan.close() }
может кто объяснить, почему так делать неочень?
Наверное, потому что fold с побочным эффектом. Кмк в этом конкретном случае это скорее дело религии.
Обсуждают сегодня