<Variant>
  <CustomDataType>
    <UInt/>
    <FloatArray/>
  </CustomDataType>
  <CustomDataType>
    <Int/>
    <ByteArray/></CustomDataType>
  <CustomDataType>
    <String/>
    <Byte>
  </CustomDataType>
</Variant>

#region Get metadata
var publishSubscribeClient = new EasyUAPublishSubscribeClient();
IUAReadOnlyPubSubConfiguration pubSubConfiguration = publishSubscribeClient.AccessReadOnlyConfiguration("opc.tcp://10.42.29.58:4840");
var pubSubConnectionNames = pubSubConfiguration.FindPublishedDataSetElement("<datasetName>", null);
var metaData = pubSubConnectionNames.DataSetMetaData;
#endregion Get metadata

using OpcLabs.EasyOpc.UA.PubSub;
using OpcLabs.EasyOpc.UA.PubSub.Configuration;
using OpcLabs.EasyOpc.UA.PubSub.InformationModel;
using OpcLabs.EasyOpc.UA.PubSub.OperationModel;
 
#region Get metadata
var publishSubscribeClient = new EasyUAPublishSubscribeClient();
IUAReadOnlyPubSubConfiguration pubSubConfiguration = publishSubscribeClient.AccessReadOnlyConfiguration("opc.tcp://10.42.29.58:4840");
var pubSubConnectionNames = pubSubConfiguration.FindPublishedDataSetElement("<datasetName>", null);
var metaData = pubSubConnectionNames.DataSetMetaData;
#endregion Get metadata
 
UAPubSubConnectionDescriptor pubSubConnectionDescriptor = "opc.udp://224.0.0.22:4840";
pubSubConnectionDescriptor.ResourceAddress.InterfaceName = "<myAdapter>";
var filter = new UASubscribeDataSetFilter(UAPublisherId.CreateUInt16(390), writerGroupDescriptor: 100);
 
// Instantiate the subscriber object and hook events.
var subscriber = new EasyUASubscriber();
subscriber.DataSetMessage += subscriber_DataSetMessage_ExtractField;
 
Console.WriteLine("Subscribing...");
subscriber.SubscribeDataSet(pubSubConnectionDescriptor, filter, metaData);
Console.WriteLine("Processing dataset message events for 20 seconds...");
Thread.Sleep(20 * 1000);
Console.WriteLine("Unsubscribing...");
subscriber.UnsubscribeAllDataSets();
 
Console.WriteLine("Waiting for 1 second...");
// Unsubscribe operation is asynchronous, messages may still come for a short while.
Thread.Sleep(1 * 1000);
Console.WriteLine("Finished.");
 
static void subscriber_DataSetMessage_ExtractField(object sender, EasyUADataSetMessageEventArgs e)
{
    // Display the dataset.
    if (e.Succeeded)
    {
        // An event with null DataSetData just indicates a successful connection.
        if (!(e.DataSetData is null))
        {
            // // Extract field data, looking up the field by its name. UADataSetFieldData
            // int32FastValueData = e.DataSetData.FieldDataDictionary["Int32Fast"]; Console.WriteLine(int32FastValueData);
        }
    }
    else
    {
        Console.WriteLine($"*** Failure: {e.ErrorMessageBrief}");
    }
}