AddictedCS

// use FFmpegAudioService
var audioService = new FFmpegAudioService();

// query file
string queryAudioFile = "query.mp3";

// connect to Emy on port 3399
var emyModelService = EmyModelService.NewInstance("localhost", 3399);
  
 // query Emy database

AddictedCS

var pathToAudioFile = "adelle.mp3";

// use FFmpegAudioService
var audioService = new FFmpegAudioService();

// connect to Emy on port 3399
var emyModelService = EmyModelService.NewInstance("localhost", 3399);
    
// define track info
var track = new TrackInfo("GBBKS1200164", "Skyfall", "Adele", new Dictionary<string, string> {{ "Market", "US" }});

AddictedCS

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);
    }