This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new b815b4eaa Add TODO note for Scala 3 workaround
b815b4eaa is described below
commit b815b4eaa1789639ad0ea31b48512ceb5020e12f
Author: Matthew de Detrich <[email protected]>
AuthorDate: Mon Aug 21 15:52:51 2023 +0200
Add TODO note for Scala 3 workaround
---
.../main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala | 1 +
1 file changed, 1 insertion(+)
diff --git
a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala
b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala
index 78c47caa6..5fba9b443 100644
---
a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala
+++
b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala
@@ -1177,6 +1177,7 @@ import scala.util.{ Failure, Success, Try }
import conf.multipartUploadSettings.retrySettings._
+ // TODO: Scala 3 workaround, see
https://github.com/lampepfl/dotty/issues/18438
val source1: SubFlow[Chunk, NotUsed, Flow[ByteString, ByteString,
NotUsed]#Repr, Sink[ByteString, NotUsed]] =
SplitAfterSize(chunkSize, chunkBufferSize)(atLeastOneByteString)
.via(getChunkBuffer(chunkSize, chunkBufferSize, maxRetries)) //
creates the chunks
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
