in rocketmq-client-csharp/Client.cs [351:362]
public void createSession(string url)
{
var metadata = new grpc::Metadata();
Signature.sign(this, metadata);
var stream = Manager.Telemetry(url, metadata);
var session = new Session(url, stream, this);
_sessions.TryAdd(url, session);
Task.Run(async () =>
{
await session.Loop();
});
}