my application is something broadcast server, pseudo code like this:
BufferedSocket:
vector<shared_ptr<Message>> messages_;
OnRead():
while(shared_ptr<Message> m = read())
//this is important
BroadMessageToAll(m)
OnWrite():
Buffer buffer = CombineMessageToBuffer(messages_)
write(buffer)
EventLoop:
vector<shared_ptr<BufferedSocket>> sockets = epoll_wait()
for each socket in sockets:
if socket.readable()
socket.OnRead()
if socket.writable()
socket.OnWrite()
I want gather write option, call system call "write" once to send everything(maybe twice). that is what i do in cpp.
how can i do this thing in rust?
or there is a better way?
thanks a lot.
The text was updated successfully, but these errors were encountered:
We do not currently have an epoll/select abstraction. The current answer is "spawn a task per socket". Tracking select/epoll is done in #6842, so closing in favor of that issue.
my application is something broadcast server, pseudo code like this:
I want gather write option, call system call "write" once to send everything(maybe twice). that is what i do in cpp.
how can i do this thing in rust?
or there is a better way?
thanks a lot.
The text was updated successfully, but these errors were encountered: