We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c76bddf commit 0f3b7eeCopy full SHA for 0f3b7ee
RSocket.Core/RSocket.Receiver.cs
@@ -35,8 +35,8 @@ public async Task<T> ExecuteAsync(CancellationToken cancellation = default)
35
return Disposable.Empty;
36
});
37
38
- var (metadata, data) = await observable.ToTask(cancellation);
39
- return Mapper((data, metadata));
+ var value = await observable.ToTask(cancellation);
+ return Mapper((value.data, value.metadata));
40
}
41
42
public async Task<T> ExecuteAsync(T result, CancellationToken cancellation = default)
@@ -58,7 +58,6 @@ public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken cancellation = d
58
return observable
59
.Select(value => Mapper((value.data, value.metadata)))
60
.ToAsyncEnumerable()
61
-
62
.GetAsyncEnumerator(cancellation);
63
64
0 commit comments