public override IEnumerable Deserialize()

in CustomDeserializers/ExampleDeserializer.cs [35:64]


        public override IEnumerable<CustomEvent> Deserialize(Stream stream)
        {
            using (var sr = new StreamReader(stream))
            {
                string line = sr.ReadLine();
                while (line != null)
                {
                    if (line.Length > 0 && !string.IsNullOrWhiteSpace(line))
                    {
                        string[] parts = line.Split(',');
                        if (parts.Length != 3)
                        {
                            //if there are not 3 columns in the input, write error to diagnostic log, skip the line and continue deserializing rest of the stream.
                            streamingDiagnostics.WriteError("Did not get expected number of columns", $"Invalid line: {line}");
                        }
                        else
                        {
                            // create a new CustomEvent object with 3 values
                            yield return new CustomEvent()
                            {
                                Column1 = parts[0],
                                Column2 = parts[1],
                                Column3 = parts[2]
                            };
                        }
                    }
                    line = sr.ReadLine();
                }
            }
        }