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

=str fix typo in internal type (RejectAdditionalSubscribers)

Browse source
This commit is contained in:
Mathias 2015-04-23 17:27:28 +02:00
parent ae430f0521
commit 15b95ab0e5
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala
View file

@ -53,7 +53,7 @@ private[akka] case object CancelledSubscription extends Subscription {
/** /**
* INTERNAL API * INTERNAL API
*/ */
private[akka] case object RejectAdditionalSubscibers extends Publisher[Nothing] { private[akka] case object RejectAdditionalSubscribers extends Publisher[Nothing] {
import ReactiveStreamsCompliance._ import ReactiveStreamsCompliance._
override def subscribe(subscriber: Subscriber[_ >: Nothing]): Unit = override def subscribe(subscriber: Subscriber[_ >: Nothing]): Unit =
try { try {

2
akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala
View file

@ -312,7 +312,7 @@ private[stream] class VirtualPublisher[T]() extends Publisher[T] {
val sub = realPublisher.subscribe(s) val sub = realPublisher.subscribe(s)
// unreference the realPublisher to facilitate GC and // unreference the realPublisher to facilitate GC and
// Sink.publisher is supposed to reject additional subscribers anyway // Sink.publisher is supposed to reject additional subscribers anyway
realPublisher = RejectAdditionalSubscibers[T] realPublisher = RejectAdditionalSubscribers[T]
sub sub
} }
} }