eu.bandm.tools.message

Class MessageMapper<M extends Message,N extends Message>

java.lang.Object

eu.bandm.tools.message.SingleSender<N>

eu.bandm.tools.message.MessageMapper<M,N>

All Implemented Interfaces:

MessageReceiver<M>

public class MessageMapper<M extends Message,N extends Message>
extends SingleSender<N>
implements MessageReceiver<M>

A message receiver which receives a message of one type, and propagates the result of applying a function to this message, which may be of different type.

Field Summary

Fields

Modifier and Type	Field and Description
protected Function<? super M,? extends N>	fun

Fields inherited from class eu.bandm.tools.message.SingleSender

receiver

Constructor Summary

Constructors

Constructor and Description
MessageMapper(Function<? super M,? extends N> fun) Factory method which creates a MessageMapper which will apply the specified function to each received message.x1

Method Summary

Modifier and Type	Method and Description
static <M extends Message,N extends Message> Function<MessageReceiver<N>,MessageReceiver<M>>	lift(Function<M,? extends N> f) Delivers a function to apply on a message receiver for type "N" to get a message receiver for type "M", when a function is given which maps the messages the other way round.
void	receive(M message)

Methods inherited from class eu.bandm.tools.message.SingleSender

getReceiver, send, setReceiver

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

fun

protected final Function<? super M extends Message,? extends N extends Message> fun

Constructor Detail

MessageMapper

public MessageMapper(Function<? super M,? extends N> fun)

Factory method which creates a MessageMapper which will apply the specified function to each received message.x1

Method Detail

receive

public void receive(M message)

Specified by:

receive in interface MessageReceiver<M extends Message>

lift

public static <M extends Message,N extends Message> Function<MessageReceiver<N>,MessageReceiver<M>> lift(Function<M,? extends N> f)

Delivers a function to apply on a message receiver for type "N" to get a message receiver for type "M", when a function is given which maps the messages the other way round.