// Namespace reference

var realtime = DataServices.Instance.Realtime;
 
// Create a subscription to 1 or more instruments specifying fields of interest

var subscription = realtime.SetupDataSubscription()

                               .WithRics("EUR=", "GBP=")

                               .WithFields("DSPLY_NAME", "BID", "ASK")

                               .OnDataUpdated(DataCallback)

                               .CreateAndStart();



// To capture updates, create a reference to the callback

private void DataCallback(IRealtimeUpdateDictionary updates)

{

    // Iterate through all updates

    foreach (var update in updates)

    {

        Console.WriteLine($"Update for item: {update.Key}");

        

        // For each instrument, display the field values

        foreach (var value in update.Value)

        {

            Console.WriteLine($"\t{value.Key} => {value.Value.Value}");

        }

    }

}

        
        Copy
    

    	
            
// Namespace reference

var realtime = DataServices.Instance.Realtime;
 
// Create a subscription to the Nasdaq Top 25 chain (.AV.O)

var chainSubscription = realtime.SetupChainSubscription(".AV.O")

                                     .OnDataUpdated(ChainUpdatedCallback)

                                     .CreateAndStart();




// To capture updates, create a reference to the callback
private void ChainUpdatedCallback(ChainChunk chainChunk)

{

    // Iterate through the chain to capture each update

    foreach (var update in chainChunk.Updates)

    {

        // The following actions describe how a chain can be updated

        switch (update.UpdateType)

        {

            case UpdateType.Added:

                Console.WriteLine($"{update.Ric} added at position {update.Position}");

                break;

            case UpdateType.Removed:

                Console.WriteLine($"{update.Ric} removed");

                break;

            case UpdateType.Changed:

                Console.WriteLine($"{update.Ric} position changed to {update.Position}");

                break;

        }

    }


    if (chainChunk.IsLast)

    {

        Console.WriteLine("---------End of update---------");

        Console.WriteLine();

    }

}

        
        Copy
    

    	
            
// Create a streaming price interface for a list of instruments

// specify lambda expressions to capture real-time events
using var stream = Pricing.Definition("EUR=", "GBP=")

                      .Fields("DSPLY_NAME", "BID", "ASK")

                      .GetStream().OnRefresh((item, refresh, s) => Console.WriteLine(refresh))

                                  .OnUpdate((item, update, s) => DisplayUpdate(item, update))

                                  .OnStatus((item, status, s) => Console.WriteLine(status));

stream.Open();
 
// Pause on the main thread while updates come in.  Wait for a key press to exit.

Console.WriteLine("Streaming updates.  Press any key to stop...");

Console.ReadKey();
 
// Based on market data events, reach into the message and pull out the fields of interest for our display.
private static void DisplayUpdate(string item, JObject update)

{

    var fields = update["Fields"];
    // Display the quote for the asset we're watching

    Console.WriteLine($"{ DateTime.Now:HH:mm:ss} Seqno: {update["SeqNumber"], -6} => {item}" +

                              $"({fields["BID"],6}/{fields["ASK"],6}) - {fields["DSPLY_NAME"]}");


}

        
        Copy
    

    	
            
// Create a subscription to the Nasdaq Top 25 chain (.AV.O) specifying the lambda expressions 

// to capture chain events

using var chain = Chain.Definition(".AV.O").GetStream()


                        .OnAdd((index, newv, stream) =>

                                Console.WriteLine($"New constituent {newv} added at: {index}"))

                        .OnRemove((index, oldv, stream) =>

                                Console.WriteLine($"Removed constituent {oldv} added at: {index}"))

                        .OnUpdate((index, oldv, newv, stream) =>

                                Console.WriteLine($"Index {index} changed from {oldv} => {newv}"));




chain.Open();
 
// Pause on the main thread while updates come in.  Wait for a key press to exit.

Console.WriteLine("Streaming updates.  Press any key to stop...");

Console.ReadKey();



        
        Copy