AdlsDotNetSDK/PoisonJob.cs (22 lines of code) (raw):
using System;
namespace Microsoft.Azure.DataLake.Store
{
/// <summary>
/// Poison job that is enqueued in the priority queue when the enumeration by the producer thread is completed.
/// The priority of the poison job is negative so it will always be polled at end when no jobs are left.
/// </summary>
internal class PoisonJob : BaseJob
{
internal PoisonJob() : base(-1)
{
}
protected override string JobDetails()
{
throw new NotImplementedException();
}
protected override string JobType()
{
throw new NotImplementedException();
}
protected override object DoJob()
{
throw new NotImplementedException();
}
}
}