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 8ad721a4a remove unnecessary conversion (#1259)
8ad721a4a is described below
commit 8ad721a4a1679b8616b1a566de15751daad604ee
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Oct 22 15:38:39 2025 +0100
remove unnecessary conversion (#1259)
---
.../pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala | 1 -
1 file changed, 1 deletion(-)
diff --git
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala
index cd6d373d6..e5aff3813 100644
---
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala
+++
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala
@@ -272,7 +272,6 @@ final class CassandraSession(system:
pekko.actor.ActorSystem,
def selectAll(stmt: Statement[_]): Future[immutable.Seq[Row]] = {
select(stmt)
.runWith(Sink.seq)
- .map(_.toVector) // Sink.seq returns Seq, not immutable.Seq (compilation
issue in Eclipse)
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
