val receivedMessages: <ERROR CLASS><MessageTransfer>
A stream of (sender, message, recipients) triples