|
46 | 46 | import com.google.common.collect.ImmutableList; |
47 | 47 | import com.google.protobuf.ByteString; |
48 | 48 | import com.google.protobuf.BytesValue; |
49 | | -import com.google.protobuf.GeneratedMessageV3; |
| 49 | +import com.google.protobuf.Message; |
50 | 50 | import com.google.protobuf.StringValue; |
51 | 51 | import io.grpc.BindableService; |
52 | 52 | import io.grpc.MethodDescriptor; |
@@ -252,15 +252,13 @@ public ServerServiceDefinition bindService() { |
252 | 252 | BigtableGrpc.getReadRowsMethod(), |
253 | 253 | ServerCalls.asyncServerStreamingCall( |
254 | 254 | (req, observer) -> rpcs.add(ServerRpc.create(req, observer)))); |
255 | | - ImmutableList<MethodDescriptor<? extends GeneratedMessageV3, ? extends GeneratedMessageV3>> |
256 | | - unaryDescriptors = |
257 | | - ImmutableList.of( |
258 | | - BigtableGrpc.getMutateRowMethod(), |
259 | | - BigtableGrpc.getCheckAndMutateRowMethod(), |
260 | | - BigtableGrpc.getReadModifyWriteRowMethod()); |
261 | | - |
262 | | - for (MethodDescriptor<? extends GeneratedMessageV3, ? extends GeneratedMessageV3> desc : |
263 | | - unaryDescriptors) { |
| 255 | + ImmutableList<MethodDescriptor<? extends Message, ? extends Message>> unaryDescriptors = |
| 256 | + ImmutableList.of( |
| 257 | + BigtableGrpc.getMutateRowMethod(), |
| 258 | + BigtableGrpc.getCheckAndMutateRowMethod(), |
| 259 | + BigtableGrpc.getReadModifyWriteRowMethod()); |
| 260 | + |
| 261 | + for (MethodDescriptor<? extends Message, ? extends Message> desc : unaryDescriptors) { |
264 | 262 | builder.addMethod( |
265 | 263 | desc.toBuilder().setType(MethodDescriptor.MethodType.SERVER_STREAMING).build(), |
266 | 264 | ServerCalls.asyncServerStreamingCall( |
|
0 commit comments