protected override TimeSpan? GetBatchFinishedTimeout()

in src/Epam.Kafka.PubSub/Subscription/SubscriptionBackgroundService.cs [81:97]


    protected override TimeSpan? GetBatchFinishedTimeout(SubscriptionBatchResult subscriptionBatchResult)
    {
        TimeSpan? timeout = null;

        if (subscriptionBatchResult == SubscriptionBatchResult.Paused && this.Options.BatchPausedTimeout.Ticks > 0)
        {
            timeout = this.Options.BatchPausedTimeout;
        }

        if (subscriptionBatchResult == SubscriptionBatchResult.NotAssigned &&
            this.Options.BatchNotAssignedTimeout.Ticks > 0)
        {
            timeout = this.Options.BatchNotAssignedTimeout;
        }

        return timeout;
    }