а потом придет с вопросами про докер

к счастью докер в жаба-экосистеме не нужен

к счастью докер в жаба-экосистеме не нужен

Всем привет
Пробую использовать Alpakka (akka-stream-alpakka-s3) для аплоада медиа файлов на AWS S3
Картинки приходят в пост реквесте (http4s) в request body (EntityBody[F])
Загоняю в инпут стрим, который загружаю альпаккой на S3.

Немного упрощенно:

def uploadToS3_example(req: Request[IO], attributes: Attributes) = {

    val bucketName = "bucketName"
    val key = "key"
    val contentType = ContentType.parse("image/jpeg").right.get
    val metaData = MetaHeaders(Map("Content-Type" -> "image/jpeg", "Cache-Control" -> "max-age = 3600"))
    val accessControlList = CannedAcl.PublicRead

    req.body
      .through(toInputStream)
      .evalMap(inputStream => IO(
        
        StreamConverters
          .fromInputStream(() => inputStream)
          .runWith(
            S3.multipartUpload(bucketName, key, contentType, metaData, accessControlList)
              .withAttributes(attributes)
          )

      ))
      .compile
      .drain
  }

Картинка на S3 успешно создается, но с размером 0 байт.
При этом точно такая же загрузка на S3 альпаккой инпут стрима, созданного из URL картинки выполняется без проблем.

Тип инпут стрима
для http4s - fs2.io.JavaInputOutputStream$$anon$1@23ce62b7
для URL - sun.net.www.protocol.http.HttpURLConnection$HttpInputStream@119bc58a

Может в этом проблема? Альпакка не дружит с JavaInputOutputStream?
Или что-то не так делаю?

С aws sdk все работает.

Буду благодарен за идеи и подсказки

Добрый день, любезные!
Возник вопрос из области Akka, Play - не могу сообразить никак.
Хочу в виде эксперимента изнутри Future запустить другое Future, но чтобы оно не было привязано к тому Future в котором все это происходит, а выполнялось паралельно, в то время когда даже . Что-то вот такое:

def anotherWork(): Future[Unit] = { .... }

def doSomething(): Future[String] = {
  // Хочу запустить anotherWork в фоне, чтобы doSomething не ожидал его завершения
  Future.successful("Main work is complete")
}

Доступ к

ActorSystem

есть.

То есть, фактически, хочется 2 фьючи запустить параллельно?