JX Application Framework
|
#include <JAsynchDataReceiver.h>
Public Member Functions | |
JAsynchDataReceiver () | |
JAsynchDataReceiver (const ACE_HANDLE fd) | |
~JAsynchDataReceiver () override | |
JSize | GetBufferSize () const |
void | SetBufferSize (const JSize bufferSize) |
int | handle_input (ACE_HANDLE) override |
![]() | |
JBroadcaster () | |
virtual | ~JBroadcaster () |
JBroadcaster & | operator= (const JBroadcaster &source) |
bool | HasSenders () const |
JSize | GetSenderCount () const |
bool | HasRecipients () const |
JSize | GetRecipientCount () const |
virtual JString | ToString () const |
template<class T > | |
void | ListenTo (const JBroadcaster *sender, const std::function< void(const T &)> &f) |
Additional Inherited Members | |
![]() | |
JBroadcaster (const JBroadcaster &source) | |
void | ListenTo (const JBroadcaster *sender) |
void | StopListening (const JBroadcaster *sender) |
void | ClearWhenGoingAway (const JBroadcaster *sender, void *pointerToMember) |
void | StopListening (const JBroadcaster *sender, const std::type_info &messageType) |
template<class T > | |
void | Send (JBroadcaster *recipient, const T &message) |
template<class T > | |
void | Broadcast (const T &message) |
virtual void | Receive (JBroadcaster *sender, const Message &message) |
void | SendWithFeedback (JBroadcaster *recipient, Message *message) |
void | BroadcastWithFeedback (Message *message) |
virtual void | ReceiveWithFeedback (JBroadcaster *sender, Message *message) |
virtual void | ReceiveGoingAway (JBroadcaster *sender) |
JAsynchDataReceiver< ACE_PEER_STREAM_1 >::JAsynchDataReceiver | ( | ) |
Receives data asynchronously and broadcasts.
JAsynchDataReceiver< ACE_PEER_STREAM_1 >::JAsynchDataReceiver | ( | const ACE_HANDLE | fd | ) |
|
override |
JSize JAsynchDataReceiver< ACE_PEER_STREAM_1 >::GetBufferSize | ( | ) | const |
This controls how much is read from the connection at one time.
|
override |
This is called when we receive data. It is also safe for anybody else to call it.
void JAsynchDataReceiver< ACE_PEER_STREAM_1 >::SetBufferSize | ( | const JSize | bufferSize | ) |