|
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 |
Public Member Functions inherited from JBroadcaster | |
| 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 | |
Protected Member Functions inherited from JBroadcaster | |
| 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 | ) |