This library implements the channel model of interprocess communication.
Channels are one model of interprocess communication that has its roots in communicating sequential process (CSP). With channels it is possible to realize processing graphs, that can be used for more than one execution, compared to a graph that is setup with futures. Channels consist of a sending and a receiving part. Each receiver has an attached process that gets executed when a value is send through. It is possible to split, zip, zip_with, or merge channels. Each processing node is associated with a process.
Creates a pair that consists of a sender and a receiver(template function)
Creates a future that joins all passed arguments. This function is deprecated and it will soon be removed. Please use instead of(template function)
Creates a receiver that merges all passed arguments. This function is deprecated and will be removed soon. Please instead(template function)
Creates a channel that merges all passed arguments(template function)
Describes a process that gets executed whenever a value is passed into the channel(policy class)
Implements the receiving part of a CSP channel(template class)
Implements the sending part of a CSP channel(template class)
It zips the values in step from all upstream receivers. (The functionality has changed after release 1.2.0!)(template function)
Creates a channel that zips multiple channels into a single one(template function)