Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-05 16:41:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement IAsyncDisposable for all ASF classes that can make use of it

Browse Source
This commit is contained in:
JustArchi
2020-04-18 17:52:11 +02:00
parent 1fe3d57cc8
commit b23f634c9b
8 changed files with 68 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
ArchiSteamFarm/WebBrowser.cs
View File

@@ -114,7 +114,7 @@ namespace ArchiSteamFarm {
HtmlDocumentResponse result = null;
for (int i = 0; i < maxTries; i++) {
using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
if (response == null) {
return null;
@@ -163,7 +163,7 @@ namespace ArchiSteamFarm {
ObjectResponse<T> result = null;
for (byte i = 0; i < maxTries; i++) {
using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
// ReSharper disable once UseNullPropagationWhenPossible - false check
if (response == null) {
@@ -219,7 +219,7 @@ namespace ArchiSteamFarm {
XmlDocumentResponse result = null;
for (byte i = 0; i < maxTries; i++) {
using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
// ReSharper disable once UseNullPropagationWhenPossible - false check
if (response == null) {
@@ -345,7 +345,7 @@ namespace ArchiSteamFarm {
HtmlDocumentResponse result = null;
for (int i = 0; i < maxTries; i++) {
using StreamResponse response = await UrlPostToStream(request, data, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlPostToStream(request, data, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
if (response == null) {
return null;
@@ -394,7 +394,7 @@ namespace ArchiSteamFarm {
ObjectResponse<T> result = null;
for (byte i = 0; i < maxTries; i++) {
using StreamResponse response = await UrlPostToStream(request, data, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlPostToStream(request, data, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
if (response == null) {
return null;
@@ -479,7 +479,7 @@ namespace ArchiSteamFarm {
const byte printPercentage = 10;
const byte maxBatches = 99 / printPercentage;
using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
await using StreamResponse response = await UrlGetToStream(request, referer, requestOptions | ERequestOptions.ReturnClientErrors, 1).ConfigureAwait(false);
if (response == null) {
continue;
@@ -915,7 +915,7 @@ namespace ArchiSteamFarm {
}
}
internal sealed class StreamResponse : BasicResponse, IDisposable {
internal sealed class StreamResponse : BasicResponse, IAsyncDisposable {
internal readonly Stream Content;
internal readonly uint Length;
@@ -938,8 +938,10 @@ namespace ArchiSteamFarm {
ResponseMessage = httpResponseMessage;
}
public void Dispose() {
Content?.Dispose();
public async ValueTask DisposeAsync() {
if (Content != null) {
await Content.DisposeAsync().ConfigureAwait(false);
}
ResponseMessage.Dispose();
}