aljaz/btcpayserver
1
0
Fork 0
mirror of https://github.com/aljazceru/btcpayserver.git synced 2026-01-03 06:04:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix listen loop for LND

Browse Source
This commit is contained in:
nicolas.dorier
2018-07-09 01:08:09 +09:00
parent 9eb36a8b40
commit 73cb3dc4ee
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
BTCPayServer/Payments/Lightning/Lnd/LndInvoiceClient.cs
View File

@@ -38,19 +38,19 @@ namespace BTCPayServer.Payments.Lightning.Lnd
urlBuilder.Append(_Parent.BaseUrl).Append("/v1/invoices/subscribe");
try
{
while (!_Cts.IsCancellationRequested)
using (var client = _Parent.CreateHttpClient())
{
using (var client = _Parent.CreateHttpClient())
client.Timeout = TimeSpan.FromMilliseconds(Timeout.Infinite);
var request = new HttpRequestMessage(HttpMethod.Get, urlBuilder.ToString());
using (var response = await client.SendAsync(
request, HttpCompletionOption.ResponseHeadersRead, _Cts.Token))
{
client.Timeout = TimeSpan.FromMilliseconds(Timeout.Infinite);
var request = new HttpRequestMessage(HttpMethod.Get, urlBuilder.ToString());
using (var response = await client.SendAsync(
request, HttpCompletionOption.ResponseHeadersRead, _Cts.Token))
using (var body = await response.Content.ReadAsStreamAsync())
using (var reader = new StreamReader(body))
{
using (var body = await response.Content.ReadAsStreamAsync())
using (var reader = new StreamReader(body))
while (!_Cts.IsCancellationRequested)
{
string line = await reader.ReadLineAsync().WithCancellation(_Cts.Token);
if (line != null && line.StartsWith("{\"result\":", StringComparison.OrdinalIgnoreCase))