How to know if the kafka stream is ready to starting consuming about kafka-streams-dotnet HOT 3 CLOSED

config.AutoOffsetReset = Confluent.Kafka.AutoOffsetReset.Earliest;

bool isRunningState  = false;
var timeout = TimeSpan.FromSeconds(100);
            stream.StateChanged += (old, @new) =>
            {
                if (@new.Equals(KafkaStream.State.RUNNING))
                {
                    isRunningState = true;
                }
            };
            await stream.StartAsync();
            while (!isRunningState)
            {
                Thread.Sleep(100);
                if (DateTime.Now > dt + timeout)
                {
                    break;
                }
            }

// Your stream is running with partition assigned