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 aebbf4965 Accept any materializer type param for S3's chunkUploadSink
aebbf4965 is described below
commit aebbf49658edd65fa47d96118fe07e1354c2b7f3
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sun Nov 12 15:36:34 2023 +0100
Accept any materializer type param for S3's chunkUploadSink
---
.../scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
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 5fba9b443..7b88ad6c8 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
@@ -906,7 +906,7 @@ import scala.util.{ Failure, Success, Try }
*/
def multipartUploadWithContext[C](
s3Location: S3Location,
- chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]),
NotUsed],
+ chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]), _],
contentType: ContentType = ContentTypes.`application/octet-stream`,
s3Headers: S3Headers,
chunkSize: Int = MinChunkSize,
@@ -943,7 +943,7 @@ import scala.util.{ Failure, Success, Try }
s3Location: S3Location,
uploadId: String,
previousParts: immutable.Iterable[Part],
- chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]),
NotUsed],
+ chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]), _],
contentType: ContentType = ContentTypes.`application/octet-stream`,
s3Headers: S3Headers,
chunkSize: Int = MinChunkSize,
@@ -1216,7 +1216,7 @@ import scala.util.{ Failure, Success, Try }
contentType: ContentType,
s3Headers: S3Headers,
chunkSize: Int,
- chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]),
NotUsed],
+ chunkUploadSink: Sink[(UploadPartResponse, immutable.Iterable[C]), _],
initialUploadState: Option[(String, Int)] = None)(
parallelism: Int): Flow[(ByteString, C), UploadPartResponse, NotUsed] = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
