Suggestion: to simplify the implementation you can create an async method:

```C#
private async Task SendNextMessageFromQueue() {}
```

And use `await` for your dequeue-send flow. If you catch your exceptions, its 
safe to start the initial call for `SendNextMessageFromQueue()` (from 
`BeginSendingMessages()`) as "fire and forget". The end result will be the same 
(as `ContinueWith()` does exactly that) but the code will be simpler.
You can look at a `Forget()` implementation here: 
https://github.com/datastax/csharp-driver/blob/46e8da823512f12cc4f109e6812ff611a9f14e20/src/Cassandra/Tasks/TaskHelper.cs#L380-L387

[ Full content available at: https://github.com/apache/tinkerpop/pull/1016 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to