Function send

3rdparty/libprocess/src/process.cpp:1781–1799

Future<Nothing> _send(Encoder* encoder, Socket socket);

void send(Encoder* encoder, Socket socket)
{
  _send(encoder, socket)
    .then([socket] {
      // Continue sending until this socket has no more
      // queued outgoing messages.
      return process::loop(
          None(),
          [=] { return socket_manager->next(socket); },
          [=](Encoder* encoder) -> Future<ControlFlow<Nothing>> {
            if (encoder == nullptr) {
              return Break();
            }

            return _send(encoder, socket)
              .then([]() -> ControlFlow<Nothing> { return Continue(); });
        });
    });
}


Future<Nothing> _send(Encoder* encoder, Socket socket)