The LowPrioMessageImplicits trait provides implicit objects of type Message[T[A]] for a number of general typed classes, but that are (or can be) partially overridden by higher-priority conversions in the object Message, or custom objects.
The LowestPrioMessageImplicits trait provides implicit objects of type Message[A] with PureMessage as implementation for all types, but that are partially overridden by higher-priority conversions in objects LowPrioMessageImplicits and Message, or custom objects.
Type class defining how messages sent over channels are poisoned.
Traits that marks "pure" message i.
Class that enriches a juc.Executor with additional methods.
Class that enriches a traversable with additional methods.
Class that enriches a value with additional methods.
Supertype of all termination signals.
Convenience functions to flatten pair of values created recursively by sequencing monadic operations.
Pair of values returned by operators that sequence two monadic actions (see IO and parser combinators).
Standard End-Of-Stream signal.
The object Message provides implicit objects of type Message[A] for a number of common final classes or sealed abstract classes.
Message typeclass for "pure" message.
Pass the result from a result channel to a return channel.
Pass the result from a result channel to a return channel.
the input.
the output.
Unit
Bridge a system-level input interface and a system-level output interface.
Bridge a system-level input interface and a system-level output interface. All the segments coming on the input are forwarded to the output in a tight immutable loop in the threads of the sender and the receiver without further level of indirection. If the input terminates first, the output is closed with the termination signal of the input. If the output terminates first, the input is poisoned with the termination signal of the output.
the input.
the output.
Unit
This package contains standard channels to interact with standard input/output and connect Molecule processes.
Enrich a juc.Executor with additional methods.
Enrich a juc.Executor with additional methods.
Enrich a traversable with additional methods.
Enrich a traversable with additional methods.
Enrich a value with additional methods.
Enrich a value with additional methods.
This package offers monadic process types and various combinators for monadic actions (see value members below).
This package permits to create clients and servers for UDP and TCP protocols using streaming I/O channels.
Parsing utility methods
Platform execution resources: executors, user-level threads and schedulers.
Types for process types and instances
Message definitions for request-response protocols.
Definition of segments transmited on channels.
This package defines standard signals
Stream channel interfaces
Misc utilities