abstract
class
Message[-A] extends AnyRef
Instance Constructors
-
new
Message()
Abstract Value Members
-
abstract
def
poison(a: A, signal: Signal): Unit
Concrete Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
def
either[B](mb: Message[B]): Message[Either[A, B]]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
final
def
getClass(): java.lang.Class[_]
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toSeg: Message[Seg[A]]
-
def
toString(): String
-
def
toTraversable: Message[Traversable[A]]
-
def
unmap[B](f: (B) ⇒ A): Message[B]
-
def
unmapMaybe[B](f: (B) ⇒ Option[A]): Message[B]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
def
zip[B](mb: Message[B]): Message[(A, B)]
Inherited from AnyRef
Inherited from Any
Type class defining how messages sent over channels are poisoned.
Instances of this class implement the
poisonmethod to define how messages must be poisoned. By default, every message is "pure" and the method does nothing (see PureMessage). In case a message type carries higher order channels, or other resources that must be closed cleanly if the message is discarded, the default behavior can be overriden by implementing an implicit instance of this class in the companion object of the message type (c.f. Scala's type class resolution mechanism). Thepoisonmethod will be invoked for example when a message is filtered out from a channel by afiltertransformation or when a message is sent over a channel that has already been poisoned (in which can it cannot be delivered).