handleMessage method

  1. @mustCallSuper
void handleMessage(
  1. Header header,
  2. InputStream body
)

Implementation

@mustCallSuper
void handleMessage(Header header, InputStream body) {
  switch (header.type) {
    case MessageType.validateConnection:
      if (validated == false) {
        connectionValidated.complete(true);
        validated = true;
      }
      break;
    case MessageType.reply:
      final requestId = body.readInt();

      final b = body.readByte();
      assert(b < ReplyStatus.values.length);
      final status = ReplyStatus.values[b];

      assert(replyHandleMap.containsKey(requestId));
      replyHandleMap[requestId]!(status, body);

      replyHandleMap.remove(requestId);
      break;
    default:
      break;
  }
}