@@ -48,7 +48,7 @@ private ServerCalls() {
48
48
*/
49
49
public static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncUnaryCall (
50
50
UnaryMethod <ReqT , RespT > method ) {
51
- return asyncUnaryRequestCall (method );
51
+ return new UnaryServerCallHandler <> (method );
52
52
}
53
53
54
54
/**
@@ -58,7 +58,7 @@ public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncUnaryCall(
58
58
*/
59
59
public static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncServerStreamingCall (
60
60
ServerStreamingMethod <ReqT , RespT > method ) {
61
- return asyncUnaryRequestCall (method );
61
+ return new UnaryServerCallHandler <> (method );
62
62
}
63
63
64
64
/**
@@ -68,7 +68,7 @@ public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncServerStreamingC
68
68
*/
69
69
public static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncClientStreamingCall (
70
70
ClientStreamingMethod <ReqT , RespT > method ) {
71
- return asyncStreamingRequestCall (method );
71
+ return new StreamingServerCallHandler <> (method );
72
72
}
73
73
74
74
/**
@@ -78,7 +78,7 @@ public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncClientStreamingC
78
78
*/
79
79
public static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncBidiStreamingCall (
80
80
BidiStreamingMethod <ReqT , RespT > method ) {
81
- return asyncStreamingRequestCall (method );
81
+ return new StreamingServerCallHandler <> (method );
82
82
}
83
83
84
84
/**
@@ -205,16 +205,6 @@ public void onReady() {
205
205
}
206
206
}
207
207
208
- /**
209
- * Creates a {@link ServerCallHandler} for a unary request call method of the service.
210
- *
211
- * @param method an adaptor to the actual method on the service implementation.
212
- */
213
- private static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncUnaryRequestCall (
214
- UnaryRequestMethod <ReqT , RespT > method ) {
215
- return new UnaryServerCallHandler <>(method );
216
- }
217
-
218
208
private static final class StreamingServerCallHandler <ReqT , RespT >
219
209
implements ServerCallHandler <ReqT , RespT > {
220
210
@@ -293,16 +283,6 @@ public void onReady() {
293
283
}
294
284
}
295
285
296
- /**
297
- * Creates a {@link ServerCallHandler} for a streaming request call method of the service.
298
- *
299
- * @param method an adaptor to the actual method on the service implementation.
300
- */
301
- private static <ReqT , RespT > ServerCallHandler <ReqT , RespT > asyncStreamingRequestCall (
302
- StreamingRequestMethod <ReqT , RespT > method ) {
303
- return new StreamingServerCallHandler <>(method );
304
- }
305
-
306
286
private interface UnaryRequestMethod <ReqT , RespT > {
307
287
/**
308
288
* The provided {@code responseObserver} will extend {@link ServerCallStreamObserver}.
0 commit comments