это ж к контенту относится, вроде ничего не мешает вернуть multipart

Ну вот, мне никто не ответил, опять в исходники опенждк идти(

это ж к контенту относится, вроде ничего не мешает вернуть multipart

Умеют ли браузеры такой контент парсить?

Мне всегда казалось что мультипарт энкодинг касается только реквестов. Разве нет?

ну я так понимаю, что это как когда ты download делаешь

ты реквест шлёшь

а тебе мультипартом файл сливается

я как то делал

т.е. ты файл возвращал множественными респонзами?

Множественный респонз )))

т.е. ты файл возвращал множественными респонзами?

Не помню

а тебе мультипартом файл сливается

Это не мультипарт похоже. Мутирарт это несколько видов контента в одно теле

Умеют ли браузеры такой контент парсить?

насчет браузеров не знаю, но в ресте, в почтах всяких часто вижу такое

Chunked это

а тебе мультипартом файл сливается

Видимо речь об офсетах. Типа хочу файл с 100500 байта

Так?

скорее всего да

Видимо речь об офсетах. Типа хочу файл с 100500 байта

ну основная суть, что нужно не одним респонзом весь большой файл отдавать, а по кускам

ну да это тогда _не_ про multipart

а

сорри тогда, спутал терминологию

ну основная суть, что нужно не одним респонзом весь большой файл отдавать, а по кускам

Можно скормить Source[Array[Byte]]

чтобы тот читал файл по мере отправления

ну основная суть, что нужно не одним респонзом весь большой файл отдавать, а по кускам

Запросов (сокетов) несколько? Если несколько это офсеты. Если один, то чанкед как подсказывает Вадим.

кусками

Запросов (сокетов) несколько? Если несколько это офсеты. Если один, то чанкед как подсказывает Вадим.

один да, да, уже нагуглил кое-что про chunked спасибо

в этом и был затык, я думал это называется multipart type

Можно скормить Source[Array[Byte]]

т.е. можно жахнуть просто complete(source) и акка это захендлит?

multipart это когда разные типы контента в одном "сообщении"

есть анмаршаллер для сорсов?

один да, да, уже нагуглил кое-что про chunked спасибо

Смотри еще про бэкпрэши всякие. Это киллер-фича акка-хттп.

т.е. можно жахнуть просто complete(source) и акка это захендлит?

да

да

ну тогда это вообще шикарно ) ушёл пробовать, спасибо

https://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/source-streaming-support.html

Походу обманул немного

А нет

Source[ByteString, _]

чет не разжигается никак, слишком толсто?

где толсто?

в чатике жвм

не знаю, они слишком агрессивно себя ведут, там либо хамить в ответ (некрасиво), либо я не знаю как, но похоже будет трудно

печальное место там

люди большую часть своего рабочего времени геттеры-сеттеры пишут, чего вы от них хотите, надо к ним с сожалением и пониманием относиться

расскажите лучше про ЯП с dependent types для JVM

https://github.com/JBakouny/Scallina

Уф, умылся дермецом ))

скаланы, как поставить локально sbt-1.1.0-RC1 через brew ?

А почему не через build.properties?

Ты можешь просто в build.properties указать нужную версию

скаланы, как поставить локально sbt-1.1.0-RC1 через brew ?

Так project/build.properties же

Кто нибудь уже сказал про build.properties ?

=D

ставил, vscode с плагином пробую, который требует 1.1.0-RC1 — что-то не работает, локально что ли sbt запускает

возвращаясь к вопросу о стриминге файла в ответ на хттп реквест

код на akka-http я вроде написал, вот только как теперь проверить это реквестом?

банально вот эта штука complete(HttpEntity.Chunked(ContentTypes.`text/plain(UTF-8)`, Source.repeat("hello").limit(10).map(ChunkStreamPart.apply)))

ни через браузер ни через curl нормально не отрабатывает

ставил, vscode с плагином пробую, который требует 1.1.0-RC1 — что-то не работает, локально что ли sbt запускает

нужно в консоли руками запускать

ни через браузер ни через curl нормально не отрабатывает

а что происходит?

нужно в консоли руками запускать

ага, уже понял и сделал, jump to definition один фиг не работает =\

а что происходит?

вот например в консоли ответ ➜ ~ curl -G http://localhost:8080/hello curl: (56) Recv failure: Connection reset by peer

из браузера тупо This site can’t be reached

так ты даже не подключился, о роутах речи уже нет

ты уверен что коннект то есть?

сервер запустил?

Http().bindAndHandle

подключился, recv же

curl -vvv все остальное

надо ему три раз подмигнуть

так ты даже не подключился, о роутах речи уже нет

ну так вот и странно

ERROR: S client not available

Http().bindAndHandle

это всё есть, в логах Server online at http://localhost:8080/ Press RETURN to stop...

да подключился ты. сделай verbose

Прекрасные моменты

По крайней мере, теперь я нашёл ответ на это: Пушто ФПшники в мире энтерпрайза. И защищают не скалу, а ФП.

возможно подключился не к серверу, но подключился)

* Trying ::1... * TCP_NODELAY set * Connection failed * connect to ::1 port 8080 failed: Connection refused * Trying 127.0.0.1... * TCP_NODELAY set * Connected to localhost (127.0.0.1) port 8080 (#0) > GET /hello HTTP/1.1 > Host: localhost:8080 > User-Agent: curl/7.54.0 > Accept: */* > < HTTP/1.1 200 OK < Server: akka-http/10.0.11 < Date: Fri, 08 Dec 2017 10:26:51 GMT < Transfer-Encoding: chunked < Content-Type: text/plain; charset=UTF-8 < * Recv failure: Connection reset by peer * stopped the pause stream! * Closing connection 0

Странно

+

покажи код на сервере

всё максимум просто

весь код пож-ста

val route = path("hello") { get { complete(HttpEntity.Chunked(ContentTypes.`text/plain(UTF-8)`, Source.repeat("hello").limit(10).map(ChunkStreamPart.apply))) } } val bindingFuture = Http().bindAndHandle(route, "localhost", 8080) println(s"Server online at http://localhost:8080/\nPress RETURN to stop...") StdIn.readLine() bindingFuture .flatMap(_.unbind()) .onComplete(_ => system.terminate())

это весь код в мейне

ну и implicit val system = ActorSystem("Data-export") implicit val mat = ActorMaterializer() в начале

А если просто complete(Source.repeat("hello").limit(10).map(ByteString(_))) или типа того?

А если просто complete(Source.repeat("hello").limit(10).map(ByteString(_))) или типа того?

а так я тоже делал

the same

А если просто complete(Source.repeat("hello").limit(10).map(ByteString(_))) или типа того?

просто сорс в комплит не вернёшь, нужен маршаллер, поэтому я заворачивал в HttpEntity

private def handling[Ex <: Throwable, T](exType: Class[Ex])(block: => T): Either[Ex, T] = catching(exType).either(block).asInstanceOf[Either[Ex, T]] Подскажите плиз при такой обработке ошибки насколько костыльно использовать asInstanceOf?

Как пример использования: handling(classOf[DateTimeParseException])(opt map ZonedDateTime.parse)

* Trying ::1... * TCP_NODELAY set * Connection failed * connect to ::1 port 8080 failed: Connection refused * Trying 127.0.0.1... * TCP_NODELAY set * Connected to localhost (127.0.0.1) port 8080 (#0) > GET /hello HTTP/1.1 > Host: localhost:8080 > User-Agent: curl/7.54.0 > Accept: */* > < HTTP/1.1 200 OK < Server: akka-http/10.0.11 < Date: Fri, 08 Dec 2017 10:34:13 GMT < Transfer-Encoding: chunked < Content-Type: text/plain; charset=UTF-8 < * Recv failure: Connection reset by peer * stopped the pause stream! * Closing connection 0

вот, всё тоже самое

как нынче модно тестировать софт? например написал я одну фигню. И написал к ней генератор траффика. Где подешевле все это запустить можно? В амазоне дороха

@Insferatu попробуй Source.repeat("hello\n")

либо trottle добавить как здесь https://github.com/calvinlfer/akka-http-streaming-response-examples/blob/master/src/main/scala/com/experiments/calvin/chunked/http/ChunkedStreamingRoutes.scala

.throttle(elements = 1000, per = 1 second, maximumBurst = 1, mode = ThrottleMode.Shaping)

как нынче модно тестировать софт? например написал я одну фигню. И написал к ней генератор траффика. Где подешевле все это запустить можно? В амазоне дороха

можешь scaleway. там инстансы не очень дорогие есть

@Insferatu попробуй Source.repeat("hello\n")

the same

ща чекну throttle

val s = Source.repeat("hello\n").limit(10).map(ChunkStreamPart(_)) val route = path("hello") { get { complete(HttpEntity.Chunked(ContentTypes.`text/plain(UTF-8)`, s)) } } вот это работает

можешь scaleway. там инстансы не очень дорогие есть

да, выглядит вроде норм

val s = Source.repeat("hello\n").limit(10).map(ChunkStreamPart(_)) val route = path("hello") { get { complete(HttpEntity.Chunked(ContentTypes.`text/plain(UTF-8)`, s)) } } вот это работает

у тебя это сработало?