@@ -44,7 +44,7 @@ protected Task<TResult> __RequestResponse<TMessage, TResult>(TMessage message, F
44
44
=> __RequestResponse ( _ => resultmapper ( _ . data ) , messagemapper ( message ) , metadata , tracing , service : service , method : method ) ;
45
45
46
46
private protected Task < T > __RequestResponse < T > (
47
- Func < ( ReadOnlySequence < byte > metadata , ReadOnlySequence < byte > data ) , T > resultmapper ,
47
+ Func < ( ReadOnlySequence < byte > data , ReadOnlySequence < byte > metadata ) , T > resultmapper ,
48
48
ReadOnlySequence < byte > data = default , ReadOnlySequence < byte > metadata = default , ReadOnlySequence < byte > tracing = default , string service = default , [ CallerMemberName ] string method = default )
49
49
=> Socket . RequestResponse ( resultmapper , data , new RemoteProcedureCallMetadata ( service , method , metadata , tracing ) ) ;
50
50
@@ -60,7 +60,7 @@ protected IAsyncEnumerable<TResult> __RequestStream<TMessage, TResult>(TMessage
60
60
=> __RequestStream ( result => resultmapper ( result . data ) , sourcemapper ( message ) , metadata , tracing , service : service , method : method ) ;
61
61
62
62
private protected IAsyncEnumerable < T > __RequestStream < T > (
63
- Func < ( ReadOnlySequence < byte > data , ReadOnlySequence < byte > metadata ) , T > resultmapper , //TODO This was out of order, check others!
63
+ Func < ( ReadOnlySequence < byte > data , ReadOnlySequence < byte > metadata ) , T > resultmapper ,
64
64
ReadOnlySequence < byte > data = default , ReadOnlySequence < byte > metadata = default ,
65
65
ReadOnlySequence < byte > tracing = default , string service = default , [ CallerMemberName ] string method = default )
66
66
=> Socket . RequestStream ( resultmapper , data , new RemoteProcedureCallMetadata ( service , method , metadata , tracing ) ) ;
@@ -77,7 +77,7 @@ protected IAsyncEnumerable<TResult> __RequestChannel<TMessage, TResult>(IAsyncEn
77
77
=> __RequestChannel < TMessage , TResult > ( messages , message => sourcemapper ( message ) , result => resultmapper ( result . data ) , data , metadata , tracing , service : service , method : method ) ;
78
78
79
79
private protected IAsyncEnumerable < T > __RequestChannel < TMessage , T > ( IAsyncEnumerable < TMessage > source ,
80
- Func < TMessage , ReadOnlySequence < byte > > sourcemapper , Func < ( ReadOnlySequence < byte > metadata , ReadOnlySequence < byte > data ) , T > resultmapper ,
80
+ Func < TMessage , ReadOnlySequence < byte > > sourcemapper , Func < ( ReadOnlySequence < byte > data , ReadOnlySequence < byte > metadata ) , T > resultmapper ,
81
81
ReadOnlySequence < byte > data = default , ReadOnlySequence < byte > metadata = default , ReadOnlySequence < byte > tracing = default , string service = default , [ CallerMemberName ] string method = default )
82
82
=> Socket . RequestChannel < TMessage , T > ( source , sourcemapper , resultmapper , data , new RemoteProcedureCallMetadata ( service , method , metadata , tracing ) ) ;
83
83
0 commit comments