AF
За что модерация?
Перечитал правила, где общение по IT запрещено?
Перечитал правила, где общение по IT запрещено?
Size: a a a
2021 December 01
ΛВ
В здравом смысле админов
Oℕ
не запрещено, просто есть правило, что админы могут удалять всё, что им лично не нравится в текущий момент
ΛВ
У чата есть тематика в конце концов
*
Все правильно. Модерация в этой группе нужна. Мы действительно флудили, если повторится - то можете и банить уже))
IZ
Всем привет! Подскажите плз по акка стримам.
Я получаю запрос
Я получаю запрос
Multipart/FromData, внутри там лежит стрим с полями, у каждого поля внутри ещё стрим Source[ByteString, Any]. У этого стрима я могу задать буфер, но размер буфера указывается в кол-ве элементов ByteString. А как настроить размер каждого батча такого? Хочется размер буфера в байтах все таки задавать, получится придется просто умножать размер одного батча на кол-во элементов, но вот размер этого одного элемента не могу нигде найти.Oℕ
вы скажите хотя бы какую библиотеку используете, а по возможности создайте компилируемый пример в scastie.scala-lang.org
Oℕ
akka http судя по всему
IZ
entity(as[Multipart.FormData]) { formData =>
formData
.parts // Source[Multipart.FormData.BodyPart, Any]
.flatMap { bodyPart =>
bodyPart.entity.dataBytes.buffer(???, OverflowStrategy.backpressure) // Source[ByteString, Any]
}
}IZ
вот у стрима, который
Source[ByteString, Any] как можно задать размер каждого элемента ByteString?IZ
это дополнительная операция. в конфиге akka-http наверняка должно как-то задаваться
Oℕ
а что конкретно вы хотите сделать?
S
Читайте reference.conf - может найдете. Я ставлю на то, что нет
IZ
задать размер буфера стрима в байтах)
IZ
сейчас есть возможность задать размер только в кол-ве штук ByteString)
IZ
там есть request-entity-chunk-size = 65536 b, но что-то не понял из описания оно это или нет
S
Что значит "дополнительная операция"? В чем разница между
bodyPart.entity.dataBytes.buffer(...) и bodyPart.entity.dataBytes.groupedWeighted(...)?Oℕ
ну ещё раз Simon скинул, как вы можете сгруппировать ваши существующие bytestring, так чтобы их суммарный объём в каждом элементе превышал нужное значение