c# - TWS API での reqContractDetails への 2 回目の呼び出しで通知が送信されず、ハングする

Question

一種の市場スキャナーを作成しようとしています。以下のコードは、一連のオプション コントラクトを返すことになっています。TWS API の呼び出しは、TWS から ContractEnd または Error 応答を受け取った場合にのみデータを返す非同期メソッドです。reqContractDetails() の最初の呼び出しで期待どおりに動作し、コントラクトのリストを取得し、メッセージ「ContractEnd」を受け取り、メソッドを終了します。

障害

何らかの理由で、reqContractDetails() への 2 回目の呼び出しで、TWS から通知を受け取りません。アプリケーションを停止して再起動し、サーバーへの新しい接続を開始して、再び機能させる必要があります。

アップデート

コードをリファクタリングした後、2 回目の呼び出しで「ストリームの終わりを超えて読み取ることができません」というエラーが表示されます。コールスタックはこのように見えます。

IBLibrary.dll!IBLibrary.OptionService.GetOptionsChain.AnonymousMethod__3(IBLibrary.Messages.ErrorMessage data) Line 64
IBLibrary.dll!IBLibrary.Classes.Client.error(string str) Line 42
CSharpAPI.dll!IBApi.EReader.putMessageToQueue() Line 94
CSharpAPI.dll!IBApi.EReader.Start.AnonymousMethod__9_0() Line 48

C# でのラッパーの実装

public class BaseService : IDisposable
{
  protected Client Sender { get; set; }
  protected EReader Receiver { get; set; }

  public BaseService()
  {
    Sender = new Client();
    Sender.Socket.eConnect("127.0.0.1", 7496, 0);
    Receiver = new EReader(Sender.Socket, Sender.Signal);
    Receiver.Start();

    var process = new Thread(() =>
    {
      while (Sender.Socket.IsConnected())
      {
        Sender.Signal.waitForSignal();
        Receiver.processMsgs();
      }
    })
    {
      IsBackground = true
    };

    process.Start();
  }

  public void Dispose()
  {
    Sender.Socket.eDisconnect();
  }
}

public class OptionService : BaseService
{
  public Task<List<OptionModel>> GetOptionsChain(OptionModel query)
  {
    if (query == null)
    {
      query = new OptionModel();
    }

    var process = Task.Run(() =>
    {
      var done = false;
      var id = new Random(DateTime.Now.Millisecond).Next();

      var contract = new Contract
      {
        Symbol = query.Symbol,
        SecType = "OPT",
        Exchange = "SMART",
        Currency = "USD",
        LastTradeDateOrContractMonth = query.Expiration
      };

      var contracts = new List<OptionModel>();

      Action<ErrorMessage> errorMessage = null;
      Action<ContractDetailsMessage> contractMessage = null;
      Action<ContractDetailsEndMessage> contractMessageEnd = null;

      contractMessage = (ContractDetailsMessage data) =>
      {
        contracts.Add(new OptionModel
        {
          Symbol = data.ContractDetails.Contract.Symbol,
          Right = data.ContractDetails.Contract.Right,
          Strike = data.ContractDetails.Contract.Strike,
          Expiration = data.ContractDetails.RealExpirationDate
        });
      };

      // I receive this message at first, but not the second time

      contractMessageEnd = (ContractDetailsEndMessage data) =>
      {
        done = true;
      };

      errorMessage = (ErrorMessage data) =>
      {
        var notifications = new List<int>
        {
          (int) ErrorCode.MarketDataFarmConnectionIsOK,
          (int) ErrorCode.HmdsDataFarmConnectionIsOK
        };

        if (notifications.Contains(data.ErrorCode) == false)
        {
          done = true;
        }
      };

      Sender.ErrorEvent += errorMessage;
      Sender.ContractDetailsEvent += contractMessage;
      Sender.ContractDetailsEndEvent += contractMessageEnd;
      Sender.Socket.reqContractDetails(id, contract);

      // Execute method until we get all contracts
      // The econd call to reqContractDetails doesn't return 
      // any notification, so obviously this line hangs forever

      while (done == false);

      Sender.ErrorEvent -= errorMessage;
      Sender.ContractDetailsEvent -= contractMessage;
      Sender.ContractDetailsEndEvent -= contractMessageEnd;

      return contracts;
    });

    return process;
  }
}