code: public static SubscriberState read(DataInput dataInput) throws IOException {
          return SubscriberState.builder().isMaster(dataInput.readBoolean()).serverState(dataInput.readUTF())
                          .totalUpdates(dataInput.readInt()).streamId(dataInput.readInt()).build();
      }
docs: Read the subscriber state to the given {@link DataInput}
  in the order of:
  isMaster
  serverState
  totalUpdates
  streamId
  @param dataInput the data output to write to
  @throws IOException