@@ -42,9 +42,7 @@ abstract class Response {
42
42
}
43
43
44
44
/// A gRPC response producing a single value.
45
- class ResponseFuture <R > extends DelegatingFuture <R >
46
- with _ResponseMixin <dynamic , R > {
47
- @override
45
+ class ResponseFuture <R > extends DelegatingFuture <R > implements Response {
48
46
final ClientCall <dynamic , R > _call;
49
47
50
48
static R _ensureOnlyOneResponse <R >(R ? previous, R element) {
@@ -65,21 +63,25 @@ class ResponseFuture<R> extends DelegatingFuture<R>
65
63
.fold <R ?>(null , _ensureOnlyOneResponse)
66
64
.then (_ensureOneResponse),
67
65
);
66
+
67
+ @override
68
+ Future <Map <String , String >> get headers => _call.headers;
69
+
70
+ @override
71
+ Future <Map <String , String >> get trailers => _call.trailers;
72
+
73
+ @override
74
+ Future <void > cancel () => _call.cancel ();
68
75
}
69
76
70
77
/// A gRPC response producing a stream of values.
71
- class ResponseStream <R > extends StreamView <R > with _ResponseMixin <dynamic , R > {
72
- @override
78
+ class ResponseStream <R > extends StreamView <R > implements Response {
73
79
final ClientCall <dynamic , R > _call;
74
80
75
81
ResponseStream (this ._call) : super (_call.response);
76
82
77
83
@override
78
84
ResponseFuture <R > get single => ResponseFuture (_call);
79
- }
80
-
81
- mixin _ResponseMixin <Q , R > implements Response {
82
- ClientCall <Q , R > get _call;
83
85
84
86
@override
85
87
Future <Map <String , String >> get headers => _call.headers;
0 commit comments