Skip to main content

feed

Function feed 

Source
async fn feed<S>(socket: &mut S, message: ServerMessage) -> Result<()>
where S: Sink<Message, Error = Error> + Unpin,
Expand description

Put one message in the socket’s buffer, where the batch’s flush picks it up - under the write bound, because a full buffer blocks here and a peer that stopped reading keeps it full.