BasicEnvWithGRPC DmEnvRpcImpl.cs

DmEnvRpcImpl.cs

//requests and responses are a bidirection gRPC stream.
while (await requestStream.MoveNext())
{
  // A request is received
  EnvironmentRequest envRequest = requestStream.Current;
  // add the request to the RequestQUeu
  this.requestQueue.AddRequestQueueObject(envRequest);
  // ask the session layer to do its work and generate a reponse to send to the client
  var envResponseList = await this.agentSession.HandleEnvironmentRequest();
  foreach (DmEnvRpc.V1.EnvironmentResponse ero in envResponseList)
  {
    // send a response to the client
    await responseStream.WriteAsync(ero);
  }
}