This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch 1.5.x
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/1.5.x by this push:
new a4f982efde chore: Deprecate Source#future in javadsl (#2555)
a4f982efde is described below
commit a4f982efdeff8a1cb4dfd7024a86b28e25bcef64
Author: He-Pin(kerr) <[email protected]>
AuthorDate: Wed Dec 17 17:53:35 2025 +0800
chore: Deprecate Source#future in javadsl (#2555)
* chore: Deprecate Source#future in javadsl
* Update stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
Co-authored-by: PJ Fanning <[email protected]>
---------
Co-authored-by: PJ Fanning <[email protected]>
---
.../java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java | 1 +
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 3 ++-
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git
a/stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java
b/stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java
index f379b49ce0..958948ea94 100644
---
a/stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java
+++
b/stream-tests/src/test/java/org/apache/pekko/stream/javadsl/LazyAndFutureSourcesTest.java
@@ -43,6 +43,7 @@ public class LazyAndFutureSourcesTest extends StreamTest {
// note these are minimal happy path tests to cover API, more thorough tests
are on the Scala side
@Test
+ @SuppressWarnings("deprecation")
public void future() throws Exception {
CompletionStage<List<String>> result =
Source.future(Future.successful("one")).runWith(Sink.seq(), system);
diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
index 5cc5401219..94fdf248e2 100755
--- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
@@ -391,6 +391,7 @@ object Source {
*
* Here for Java interoperability, the normal use from Java should be
[[Source.completionStage]]
*/
+ @deprecated("Use 'Source.completionStage' or 'scaladsl.Source.future'
instead", "1.5.0")
def future[T](futureElement: Future[T]): Source[T, NotUsed] =
scaladsl.Source.future(futureElement).asJava
@@ -406,7 +407,7 @@ object Source {
* If the `CompletionStage` is completed with a failure the stream is failed.
*/
def completionStage[T](completionStage: CompletionStage[T]): Source[T,
NotUsed] =
- future(completionStage.asScala)
+ new Source(scaladsl.Source.future(completionStage.asScala))
/**
* Turn a `CompletionStage[Source]` into a source that will emit the values
of the source when the future completes successfully.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
