Realtime Command usage for SoundFingerprinting

RealtimeCommandSample.cs

public class RealtimeCommandSample
{
    public async Task Run(IModelService modelService, CancellationToken cancellationToken)
    {
        var collection = new BlockingCollection<AudioSamples>();
        var producerTask = Task.Run(() => GetRealtimeData(collection, cancellationToken), cancellationToken);
        var consumerTask = QueryRealtimeData(modelService, collection, 5d, cancellationToken);
        var finished = await Task.WhenAny(producerTask, consumerTask);
        await finished.ConfigureAwait(false);
    }

    public void GetRealtimeData(BlockingCollection<AudioSamples> producer, CancellationToken cancellationToken)
    {
        while (!cancellationToken.IsCancellationRequested)
        {
            // get realtime data in chunks
            // each chunk has to contain 10240 samples, at 5512Hz, meaning each sample has to be 1.857 seconds length
            // source of the realtime data is application dependent
            float[] audioSamples = new float[10240];
            var chunk = new AudioSamples(audioSamples, "", 5512);
            producer.Add(chunk, cancellationToken);
        }

        producer.CompleteAdding();
    }

    public Task QueryRealtimeData(
        IModelService modelService,
        BlockingCollection<AudioSamples> source, 
        double lengthOfASuccessfulMatch, 
        CancellationToken cancellationToken)
    {
        var realtimeQuery = QueryCommandBuilder.Instance.BuildRealtimeQueryCommand()
            .From(source)
            .WithRealtimeQueryConfig(config =>
            {
                config.ResultEntryFilter = new QueryMatchLengthFilter(lengthOfASuccessfulMatch);
                config.SuccessCallback = entry =>
                {
                    Console.WriteLine($"Got successful match for {entry.Track.Id}");
                };
                return config;
            })
            .UsingServices(modelService)
            .Query(cancellationToken);

        return realtimeQuery;
    }
}