#include <CFanoutTransport.h>
class CFanoutTransport : public CTransport
{
public:
virtual void end() = 0;
};
Abstract base class for transports that fanout
data to several parallel workers. The only
wrinkle this abstract base class adds is a pure virtual
end method.
This is because when there's no more data to send,
all clients must be notified of that fact. That
notification is done in a transport dependent manner.