Trying to open a data stream form within a stream callback causes a deadlock

Using example "3.1.0 - Streaming - MarketPrice" and connecting via Eikon4

Replace the OnRefresh handler with the following code:

.OnRefresh((s,msg) =>
{
    Console.WriteLine(msg);
    using (IStream s_ = DeliveryFactory.CreateStream(new ItemStream.Params().Session(session).Name("CHF=")))
    {    
        s_.Open();    
        Console.WriteLine("IT WORKED"); 
    }
})

The program does not return from s_.Open() and will never print "IT WORKED".

Same result when trying to await an OpenAsync() call.

Find more posts tagged with

.net

error

rdp-api

refinitiv-data-platform

refinitiv-data-platform-libraries

Accepted answers

nick.zincone

Hi @martin.grunwald,

Yes, the above code will create a deadlock scenario. Try this:

.OnRefresh(async (s, msg) =>
{
   Console.WriteLine(msg);
   using (IStream s_ = DeliveryFactory.CreateStream(new ItemStream.Params().Session(session).Name("CHF="))
   {
      await s_.OpenAsync();
      Console.WriteLine("IT WORKED");
   }
})

All comments

nick.zincone

Hi @martin.grunwald,

Yes, the above code will create a deadlock scenario. Try this:

.OnRefresh(async (s, msg) =>
{
   Console.WriteLine(msg);
   using (IStream s_ = DeliveryFactory.CreateStream(new ItemStream.Params().Session(session).Name("CHF="))
   {
      await s_.OpenAsync();
      Console.WriteLine("IT WORKED");
   }
})

EXPLORE OUR SITES