sendRequest method

  1. @override
void sendRequest(
  1. OutputStream out,
  2. int requestId,
  3. ReplyHandle handle
)
override

Implementation

@override
void sendRequest(OutputStream out, int requestId, ReplyHandle handle) {
  assert(!replyHandleMap.containsKey(requestId));
  replyHandleMap[requestId] = handle;

  final buf = out.finished();

  if (validated) {
    socket.add(buf);
  } else {
    connectionValidated.future.then((v) {
      socket.add(buf);
    });
  }
}