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

Merge pull request #16234 from akka/wip-scaladoc-warns-patriknw

Browse source 
=str Fix scaladoc warnings
This commit is contained in:
Patrik Nordwall 2014-11-06 15:36:41 +01:00
commit e0b159475e
8 changed files with 34 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -21,18 +21,19 @@ trait Source[+Out] extends FlowOps[Out] {
override type Repr[+O] <: Source[O]
/**
* Transform this [[Source]] by appending the given processing stages.
* Transform this [[akka.stream.scaladsl.Source]] by appending the given processing stages.
*/
def via[T](flow: Flow[Out, T]): Source[T]
/**
* Connect this [[Source]] to a [[Sink]], concatenating the processing steps of both.
* Connect this [[akka.stream.scaladsl.Source]] to a [[akka.stream.scaladsl.Sink]],
* concatenating the processing steps of both.
*/
def to(sink: Sink[Out]): RunnableFlow
/**
* Connect this `Source` to a `Sink` and run it. The returned value is the materialized value
* of the `Sink`, e.g. the `Publisher` of a [[Sink.fanoutPublisher]].
* of the `Sink`, e.g. the `Publisher` of a [[akka.stream.scaladsl.Sink#publisher]].
*/
def runWith(sink: Sink[Out])(implicit materializer: FlowMaterializer): sink.MaterializedType =
to(sink).run().get(sink)