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

=str Fix some scaladoc

Browse source
This commit is contained in:
Patrik Nordwall 2015-03-06 10:23:26 +01:00
parent 53e3dcad06
commit 71d2db0552
16 changed files with 37 additions and 48 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-stream/src/main/scala/akka/stream/impl/Sinks.scala
View file

@ -43,10 +43,6 @@ class PublisherSink[In](val attributes: OperationAttributes, shape: SinkShape[In
override def toString: String = "PublisherSink"
/**
* This method is only used for Sinks that return true from [[#isActive]], which then must
* implement it.
*/
override def create(materializer: ActorFlowMaterializerImpl, flowName: String): (Subscriber[In], Publisher[In]) = {
val pub = new VirtualPublisher[In]
val sub = new VirtualSubscriber[In](pub)
@ -154,10 +150,6 @@ final class SubscriberSink[In](subscriber: Subscriber[In], val attributes: Opera
*/
final class CancelSink(val attributes: OperationAttributes, shape: SinkShape[Any]) extends SinkModule[Any, Unit](shape) {
/**
* This method is only used for Sinks that return true from [[#isActive]], which then must
* implement it.
*/
override def create(materializer: ActorFlowMaterializerImpl, flowName: String): (Subscriber[Any], Unit) = {
val subscriber = new Subscriber[Any] {
override def onError(t: Throwable): Unit = ()