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

Merge pull request #17013 from akka/wip-str-scaladoc-patriknw

Browse source 
=str Fix some scaladoc
This commit is contained in:
Patrik Nordwall 2015-03-06 15:59:21 +01:00
commit 9ea08e0743
16 changed files with 37 additions and 48 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream/src/main/scala/akka/stream/impl/Sources.scala
View file

@ -54,10 +54,6 @@ private[akka] abstract class SourceModule[+Out, +Mat](val shape: SourceShape[Out
*/
private[akka] final class SubscriberSource[Out](val attributes: OperationAttributes, shape: SourceShape[Out]) extends SourceModule[Out, Subscriber[Out]](shape) {
/**
* This method is only used for Sources that return true from [[#isActive]], which then must
* implement it.
*/
override def create(materializer: ActorFlowMaterializerImpl, flowName: String): (Publisher[Out], Subscriber[Out]) = {
val processor = new Processor[Out, Out] {
@volatile private var subscriber: Subscriber[_ >: Out] = null