From c2945a3e7f43bb51b5d32402f219babc7245f9eb Mon Sep 17 00:00:00 2001 From: contrun Date: Mon, 27 Apr 2020 22:15:28 +0800 Subject: [PATCH] Docs: API docs for asSourceWithContext (#28950) --- akka-stream/src/main/scala/akka/stream/javadsl/Source.scala | 3 +++ akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala | 3 +++ 2 files changed, 6 insertions(+) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala index f59066e6e6..e165ca33c7 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -4312,6 +4312,9 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[ def logWithMarker(name: String, marker: function.Function[Out, LogMarker]): javadsl.Source[Out, Mat] = this.logWithMarker(name, marker, ConstantFun.javaIdentityFunction[Out], null) + /** + * Transform this source whose element is ``e`` into a source producing tuple ``(e, f(e))`` + **/ def asSourceWithContext[Ctx](extractContext: function.Function[Out, Ctx]): SourceWithContext[Out, Ctx, Mat] = new scaladsl.SourceWithContext(this.asScala.map(x => (x, extractContext.apply(x)))).asJava } diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala index 993c61aeea..d399ef291e 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala @@ -246,6 +246,9 @@ final class Source[+Out, +Mat]( combineRest(2, rest.iterator) }) + /** + * Transform this source whose element is ``e`` into a source producing tuple ``(e, f(e))`` + **/ def asSourceWithContext[Ctx](f: Out => Ctx): SourceWithContext[Out, Ctx, Mat] = new SourceWithContext(this.map(e => (e, f(e)))) }