This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 504f3c271 remove unnecessary map calls (#1227)
504f3c271 is described below
commit 504f3c27125e9c57762f494edec7c9428a4751a5
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Oct 6 22:21:44 2025 +0100
remove unnecessary map calls (#1227)
* remove unnecessary map calls
* Update EventSource.scala
* Update
google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala
Co-authored-by: Arnout Engelen <[email protected]>
---------
Co-authored-by: Arnout Engelen <[email protected]>
---
.../googlecloud/bigquery/storage/ProtobufConverters.scala | 6 +++---
.../pekko/stream/connectors/googlecloud/storage/StorageObject.scala | 2 +-
.../org/apache/pekko/stream/connectors/google/GoogleSettings.scala | 2 +-
.../apache/pekko/stream/connectors/sse/javadsl/EventSource.scala | 3 ++-
4 files changed, 7 insertions(+), 6 deletions(-)
diff --git
a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala
b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala
index 67dce0162..f9add718d 100644
---
a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala
+++
b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala
@@ -49,9 +49,9 @@ import scala.jdk.CollectionConverters._
private final def unknownField(field:
com.google.protobuf.UnknownFieldSet.Field): UnknownFieldSet.Field = {
UnknownFieldSet.Field(
- varint = field.getVarintList.asScala.map(_.asInstanceOf[Long]).toSeq,
- fixed64 = field.getFixed64List.asScala.map(_.asInstanceOf[Long]).toSeq,
- fixed32 = field.getFixed32List.asScala.map(_.asInstanceOf[Int]).toSeq,
+ varint = field.getVarintList.asScala.toSeq.asInstanceOf[Seq[Long]],
+ fixed64 = field.getFixed64List.asScala.toSeq.asInstanceOf[Seq[Long]],
+ fixed32 = field.getFixed32List.asScala.toSeq.asInstanceOf[Seq[Int]],
lengthDelimited = field.getLengthDelimitedList.asScala.toSeq)
}
diff --git
a/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala
b/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala
index da3d18333..057d241e3 100644
---
a/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala
+++
b/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala
@@ -456,7 +456,7 @@ object StorageObject {
bucket,
generation,
contentType.asInstanceOf[ContentType],
- Option(contentType).map(_.asInstanceOf[ContentType]),
+ Option(contentType.asInstanceOf[ContentType]),
size,
etag,
md5Hash,
diff --git
a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala
b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala
index 4ce776407..c3de5c7ce 100644
---
a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala
+++
b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala
@@ -264,7 +264,7 @@ object ForwardProxy {
credentials: Optional[jm.headers.BasicHttpCredentials],
trustPem: Optional[String],
system: ClassicActorSystemProvider) =
- apply(scheme, host, port,
credentials.toScala.map(_.asInstanceOf[BasicHttpCredentials]),
trustPem.toScala)(system)
+ apply(scheme, host, port,
credentials.toScala.asInstanceOf[Option[BasicHttpCredentials]],
trustPem.toScala)(system)
def create(connectionContext: jh.HttpConnectionContext, poolSettings:
jh.settings.ConnectionPoolSettings) =
apply(connectionContext.asInstanceOf[HttpsConnectionContext],
poolSettings.asInstanceOf[ConnectionPoolSettings])
diff --git
a/sse/src/main/scala/org/apache/pekko/stream/connectors/sse/javadsl/EventSource.scala
b/sse/src/main/scala/org/apache/pekko/stream/connectors/sse/javadsl/EventSource.scala
index 01aa018b3..4abf970b0 100644
---
a/sse/src/main/scala/org/apache/pekko/stream/connectors/sse/javadsl/EventSource.scala
+++
b/sse/src/main/scala/org/apache/pekko/stream/connectors/sse/javadsl/EventSource.scala
@@ -28,6 +28,7 @@ import pekko.stream.javadsl.Source
import scala.jdk.FutureConverters
import scala.jdk.OptionConverters
+import scala.concurrent.Future
/**
* This stream processing stage establishes a continuous source of server-sent
events from the given URI.
@@ -91,7 +92,7 @@ object EventSource {
scaladsl
.EventSource(
uri.asScala,
-
send(_).asScala.map(_.asInstanceOf[SHttpResponse])(system.classicSystem.dispatcher),
+ send(_).asScala.asInstanceOf[Future[SHttpResponse]],
lastEventId.toScala)(system)
.map(v => v: ServerSentEvent)
eventSource.asJava
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
