FlowShape

Companion object FlowShape

final case class FlowShape[-I, +O](in: Inlet[I], out: Outlet[O]) extends Shape with Product with Serializable

A Flow Shape has exactly one input and one output, it looks from the outside like a pipe (but it can be a complex topology of streams within of course).

Source: Shape.scala

Linear Supertypes

Serializable, Serializable, Product, Equals, Shape, AnyRef, Any

Type Hierarchy

Ordering

Alphabetic
By Inheritance

Inherited

FlowShape
Serializable
Serializable
Product
Equals
Shape
AnyRef
Any

Implicitly

by any2stringadd
by StringFormat
by Ensuring
by ArrowAssoc

Hide All
Show All

Visibility

Public
All

Instance Constructors

new FlowShape(in: Inlet[I], out: Outlet[O])

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
def +(other: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to any2stringadd[FlowShape[I, O]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def copyFromPorts(inlets: Seq[Inlet[_]], outlets: Seq[Outlet[_]]): Shape
Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.
Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.

Definition Classes
FlowShape → Shape
def deepCopy(): FlowShape[I, O]
Create a copy of this Shape object, returning the same type as the original; this constraint can unfortunately not be expressed in the type system.
Create a copy of this Shape object, returning the same type as the original; this constraint can unfortunately not be expressed in the type system.

Definition Classes
FlowShape → Shape
def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def formatted(fmtstr: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to StringFormat[FlowShape[I, O]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getInlets: List[Inlet[_]]
Java API: get a list of all input ports
Java API: get a list of all input ports

Definition Classes
Shape
def getOutlets: List[Outlet[_]]
Java API: get a list of all output ports
Java API: get a list of all output ports

Definition Classes
Shape
def hasSamePortsAndShapeAs(s: Shape): Boolean
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).

Definition Classes
Shape
def hasSamePortsAs(s: Shape): Boolean
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).

Definition Classes
Shape
val in: Inlet[I]
val inlets: Seq[Inlet[_]]

Definition Classes
FlowShape → Shape
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val out: Outlet[O]
val outlets: Seq[Outlet[_]]

Definition Classes
FlowShape → Shape
def requireSamePortsAndShapeAs(s: Shape): Unit
Asserting version of #hasSamePortsAndShapeAs.
Asserting version of #hasSamePortsAndShapeAs.

Definition Classes
Shape
def requireSamePortsAs(s: Shape): Unit
Asserting version of #hasSamePortsAs.
Asserting version of #hasSamePortsAs.

Definition Classes
Shape
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def →[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Inherited from Shape

Value Members

def getInlets: List[Inlet[_]]
Java API: get a list of all input ports
Java API: get a list of all input ports

Definition Classes
Shape
def getOutlets: List[Outlet[_]]
Java API: get a list of all output ports
Java API: get a list of all output ports

Definition Classes
Shape
def hasSamePortsAndShapeAs(s: Shape): Boolean
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).

Definition Classes
Shape
def hasSamePortsAs(s: Shape): Boolean
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).

Definition Classes
Shape
def requireSamePortsAndShapeAs(s: Shape): Unit
Asserting version of #hasSamePortsAndShapeAs.
Asserting version of #hasSamePortsAndShapeAs.

Definition Classes
Shape
def requireSamePortsAs(s: Shape): Unit
Asserting version of #hasSamePortsAs.
Asserting version of #hasSamePortsAs.

Definition Classes
Shape

Inherited from AnyRef

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Inherited from Any

Value Members

final def asInstanceOf[T0]: T0

Definition Classes
Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any

Inherited by implicit conversion any2stringadd from FlowShape[I, O] to any2stringadd[FlowShape[I, O]]

Value Members

def +(other: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to any2stringadd[FlowShape[I, O]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd

Inherited by implicit conversion StringFormat from FlowShape[I, O] to StringFormat[FlowShape[I, O]]

Value Members

def formatted(fmtstr: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to StringFormat[FlowShape[I, O]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()

Inherited by implicit conversion Ensuring from FlowShape[I, O] to Ensuring[FlowShape[I, O]]

Value Members

def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring

Inherited by implicit conversion ArrowAssoc from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]]

Value Members

def ->[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
def →[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Ungrouped

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
def +(other: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to any2stringadd[FlowShape[I, O]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def copyFromPorts(inlets: Seq[Inlet[_]], outlets: Seq[Outlet[_]]): Shape
Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.
Create a copy of this Shape object, returning the same type as the original but containing the ports given within the passed-in Shape.

Definition Classes
FlowShape → Shape
def deepCopy(): FlowShape[I, O]
Create a copy of this Shape object, returning the same type as the original; this constraint can unfortunately not be expressed in the type system.
Create a copy of this Shape object, returning the same type as the original; this constraint can unfortunately not be expressed in the type system.

Definition Classes
FlowShape → Shape
def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (FlowShape[I, O]) ⇒ Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): FlowShape[I, O]

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to Ensuring[FlowShape[I, O]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def formatted(fmtstr: String): String

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to StringFormat[FlowShape[I, O]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getInlets: List[Inlet[_]]
Java API: get a list of all input ports
Java API: get a list of all input ports

Definition Classes
Shape
def getOutlets: List[Outlet[_]]
Java API: get a list of all output ports
Java API: get a list of all output ports

Definition Classes
Shape
def hasSamePortsAndShapeAs(s: Shape): Boolean
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).
Compare this to another shape and determine whether the arrangement of ports is the same (including their ordering).

Definition Classes
Shape
def hasSamePortsAs(s: Shape): Boolean
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).
Compare this to another shape and determine whether the set of ports is the same (ignoring their ordering).

Definition Classes
Shape
val in: Inlet[I]
val inlets: Seq[Inlet[_]]

Definition Classes
FlowShape → Shape
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val out: Outlet[O]
val outlets: Seq[Outlet[_]]

Definition Classes
FlowShape → Shape
def requireSamePortsAndShapeAs(s: Shape): Unit
Asserting version of #hasSamePortsAndShapeAs.
Asserting version of #hasSamePortsAndShapeAs.

Definition Classes
Shape
def requireSamePortsAs(s: Shape): Unit
Asserting version of #hasSamePortsAs.
Asserting version of #hasSamePortsAs.

Definition Classes
Shape
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def →[B](y: B): (FlowShape[I, O], B)

Implicit
This member is added by an implicit conversion from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Packages

FlowShape 

Companion object FlowShape

final case class FlowShape[-I, +O](in: Inlet[I], out: Outlet[O]) extends Shape with Product with Serializable

Instance Constructors

Value Members

Inherited from Shape

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Inherited by implicit conversion any2stringadd from FlowShape[I, O] to any2stringadd[FlowShape[I, O]]

Value Members

Inherited by implicit conversion StringFormat from FlowShape[I, O] to StringFormat[FlowShape[I, O]]

Value Members

Inherited by implicit conversion Ensuring from FlowShape[I, O] to Ensuring[FlowShape[I, O]]

Value Members

Inherited by implicit conversion ArrowAssoc from FlowShape[I, O] to ArrowAssoc[FlowShape[I, O]]

Value Members

Ungrouped

FlowShape