internal override void ReadField(RecordReader reader)
 {
     while (!reader.IsEndOfSegment)
     {
         List.Add(reader.ReadReference(FormKindSet.Any));
     }
 }

 internal UnknownRecord(Module module, RecordReader reader)
     : base(module, reader)
 {
     while (reader.ReadField()) {
         new UnknownRecordField(this, ref reader);
     }
 }

        internal UnknownRecordField(UnknownRecord record, ref RecordReader reader)
            : base(record, reader.Field.Type)
        {
            RecordField field = reader.Field;

            Data = reader.Reader.ReadBytes(field.Size);
        }

        public FormLoader(Plugin plugin, RecordReader stockReader, bool lazyLoading, int backgroundJobs)
        {
            if (backgroundJobs < 0)
                throw new ArgumentException("Number of bakcground jobs must be a positive integer or zero");

            sharedData = new SharedData()
            {
                Plugin = plugin,
                StockReader = stockReader,
                LazyLoading = lazyLoading,
                FormsToLoad = new BlockingCollection<Form>(new ConcurrentQueue<Form>(), 1024),
                WorkerCompleteEvent = new AutoResetEvent(false)
            };

            this.stockReader = stockReader;
            asyncLoading = backgroundJobs > 0;

            bool useStockReader = true;
            while (backgroundJobs-- > 0)
            {
                Worker worker = new Worker(sharedData, useStockReader);
                worker.RunWorkerCompleted += Worker_RunWorkerCompleted;
                worker.RunWorkerAsync();
                workers.Add(new WorkerInfo()
                {
                    Worker = worker
                });

                // Only the first worker can use the stock reader
                useStockReader = false;
            }
        }

 public RecordKEY(RecordReader rr)
 {
     FLAGS = rr.ReadUInt16();
     PROTOCOL = rr.ReadByte();
     ALGORITHM = rr.ReadByte();
     PUBLICKEY = rr.ReadString();
 }

 ///<summary>
 ///</summary>
 ///<param name="rr"></param>
 public RecordA(RecordReader rr)
 {
     IPAddress.TryParse(string.Format("{0}.{1}.{2}.{3}",
                                      rr.ReadByte(),
                                      rr.ReadByte(),
                                      rr.ReadByte(),
                                      rr.ReadByte()), out Address);
 }

 ///<summary>
 ///</summary>
 ///<param name="rr"></param>
 public RecordNULL(RecordReader rr)
 {
     rr.Position -= 2;
     // re-read length
     var rdlength = rr.ReadUInt16();
     Anything = new byte[rdlength];
     Anything = rr.ReadBytes(rdlength);
 }

 public RecordNXT(RecordReader rr)
 {
     ushort length = rr.ReadUInt16(-2);
     NEXTDOMAINNAME = rr.ReadDomainName();
     length -= (ushort)rr.Position;
     BITMAP = new byte[length];
     BITMAP = rr.ReadBytes(length);
 }

 ///<summary>
 ///</summary>
 ///<param name="rr"></param>
 public RecordNAPTR(RecordReader rr)
 {
     Order = rr.ReadUInt16();
     Preference = rr.ReadUInt16();
     Flags = rr.ReadString();
     Services = rr.ReadString();
     Regexp = rr.ReadString();
     Replacement = rr.ReadDomainName();
 }

        public X25Record(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_psdnAddress = recordReader.ReadString();
        }

        public NSAPPTRRecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_owner = recordReader.ReadString();
        }

 public RecordDS(RecordReader rr)
 {
     ushort length = rr.ReadUInt16(-2);
     KEYTAG = rr.ReadUInt16();
     ALGORITHM = rr.ReadByte();
     DIGESTTYPE = rr.ReadByte();
     length -= 4;
     DIGEST = new byte[length];
     DIGEST = rr.ReadBytes(length);
 }

 public RecordSOA(RecordReader rr)
 {
     MNAME = rr.ReadDomainName();
     RNAME = rr.ReadDomainName();
     SERIAL = rr.ReadUInt32();
     REFRESH = rr.ReadUInt32();
     RETRY = rr.ReadUInt32();
     EXPIRE = rr.ReadUInt32();
     MINIMUM = rr.ReadUInt32();
 }

        public MGRecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_mgmName = recordReader.ReadDomainName();
        }

        public ARecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_address = new IPAddress(recordReader.ReadBytes(4));
        }

        public MINFORecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_rMailBx = recordReader.ReadDomainName();
            m_eMailBx = recordReader.ReadDomainName();
        }

        public RTRecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_preference = recordReader.ReadUInt16();
            m_intermediateHost = recordReader.ReadDomainName();
        }

        public HINFORecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            m_cpu = recordReader.ReadString();
            m_os = recordReader.ReadString();
        }

        public NULLRecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            var count = recordReader.ReadUInt16(-1);
            m_anything = recordReader.ReadBytes(count);
        }

        public APLRecord(RR rr, RecordReader recordReader)
            : base(rr)
        {
            if (recordReader == null)
            {
                throw new ArgumentNullException("recordReader");
            }

            var count = recordReader.ReadUInt16(-2);
            m_rdata = recordReader.ReadBytes(count);
        }