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

=str minor typo fixes and scala version bump

Browse source
This commit is contained in:
Martynas Mickevičius 2015-04-13 20:10:59 +03:00
parent ee32c5bc42
commit 57e5976996
5 changed files with 14 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -15,7 +15,7 @@ import scala.collection.mutable
private[akka] object StreamLayout {
// compile-time constant
val debug = true
final val Debug = true
// TODO: Materialization order
// TODO: Special case linear composites
@ -51,7 +51,7 @@ private[akka] object StreamLayout {
this.grow(that, f).connect(from, to)
def connect[A, B](from: OutPort, to: InPort): Module = {
if (debug) validate()
if (Debug) validate()
require(outPorts(from),
if (downstreams.contains(from)) s"The output port [$from] is already connected"
@ -69,7 +69,7 @@ private[akka] object StreamLayout {
}
def transformMaterializedValue(f: Any ⇒ Any): Module = {
if (debug) validate()
if (Debug) validate()
CompositeModule(
subModules = if (this.isAtomic) Set(this) else this.subModules,
@ -82,7 +82,7 @@ private[akka] object StreamLayout {
def grow(that: Module): Module = grow(that, Keep.left)
def grow[A, B, C](that: Module, f: (A, B) ⇒ C): Module = {
if (debug) validate()
if (Debug) validate()
require(that ne this, "A module cannot be added to itself. You should pass a separate instance to grow().")
require(!subModules(that), "An existing submodule cannot be added again. All contained modules must be unique.")
@ -101,7 +101,7 @@ private[akka] object StreamLayout {
}
def wrap(): Module = {
if (debug) validate()
if (Debug) validate()
CompositeModule(
subModules = Set(this),