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

unmoored doc comment in PhasedFusingActorMaterializer (#27641)

Browse source
This commit is contained in:
Patrik Nordwall 2019-09-06 09:39:52 +02:00 • committed by Arnout Engelen
parent ed955e0da4
commit 1d38f1579a
1 changed files with 9 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala
View file

@ -387,12 +387,8 @@ private final case class SavedIslandData(
/** /**
* INTERNAL API * INTERNAL API
*/ *
@InternalApi private[akka] case class PhasedFusingActorMaterializer( * `defaultAttributes` for the materializer, based on the [[ActorMaterializerSettings]] and
system: ActorSystem,
override val settings: ActorMaterializerSettings,
/**
* Default attributes for the materializer, based on the [[ActorMaterializerSettings]] and
* are always seen as least specific, so any attribute specified in the graph "wins" over these. * are always seen as least specific, so any attribute specified in the graph "wins" over these.
* In addition to that this also guarantees that the attributes `InputBuffer`, `SupervisionStrategy`, * In addition to that this also guarantees that the attributes `InputBuffer`, `SupervisionStrategy`,
* and `Dispatcher` is _always_ present in the attributes and can be accessed through `Attributes.mandatoryAttribute` * and `Dispatcher` is _always_ present in the attributes and can be accessed through `Attributes.mandatoryAttribute`
@ -400,7 +396,10 @@ private final case class SavedIslandData(
* When these attributes are needed later in the materialization process it is important that * When these attributes are needed later in the materialization process it is important that
* they are gotten through the attributes and not through the [[ActorMaterializerSettings]] * they are gotten through the attributes and not through the [[ActorMaterializerSettings]]
*/ */
defaultAttributes: Attributes, @InternalApi private[akka] case class PhasedFusingActorMaterializer(
system: ActorSystem,
override val settings: ActorMaterializerSettings,
defaultAttributes: Attributes, // see description above
dispatchers: Dispatchers, dispatchers: Dispatchers,
supervisor: ActorRef, supervisor: ActorRef,
haveShutDown: AtomicBoolean, haveShutDown: AtomicBoolean,