raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Docs: API docs for asSourceWithContext (#28950)

Browse source
This commit is contained in:
contrun 2020-04-27 22:15:28 +08:00 • committed by GitHub
parent 2db52a06ea
commit c2945a3e7f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-stream/src/main/scala/akka/stream/javadsl/Source.scala
View file

@ -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
}

3
akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala
View file

@ -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))))
}