@Override
            public void onNext(StreamingInputCallRequest message) {
                totalPayloadSize += message.getPayload().getBody().size();
            }
Waits until we have received all of the request messages and then returns the aggregate payload
size for all of the received requests.
grpc/src/test/java/com/linecorp/armeria/internal/common/grpc/TestServiceImpl.java