com.google.protobuf.Empty#getDefaultInstance ( )源码实例Demo

private FluxInvocation(FluxSink<Object> sink, Object[] args) {
    StreamObserver<Object> grpcStreamObserver = new ClientResponseObserver<Object, Object>() {
        @Override
        public void beforeStart(ClientCallStreamObserver requestStream) {
            sink.onCancel(() -> requestStream.cancel("React subscription cancelled", null));
        }

        @Override
        public void onNext(Object value) {
            sink.next(value);
        }

        @Override
        public void onError(Throwable error) {
            sink.error(error);
        }

        @Override
        public void onCompleted() {
            sink.complete();
        }
    };

    Object[] grpcArgs = new Object[]{
            grpcArgPos < 0 ? Empty.getDefaultInstance() : args[grpcArgPos],
            grpcStreamObserver
    };

    GRPC_STUB invocationStub = handleCallMetadata(args)
            .withDeadline(Deadline.after(timeout.toMillis(), TimeUnit.MILLISECONDS));

    try {
        grpcMethod.invoke(invocationStub, grpcArgs);
    } catch (Exception e) {
        sink.error(e);
    }
}
 

private Empty broadcast(ChatProto.ChatMessage message) {
    logger.info(message.getAuthor() + ": " + message.getMessage());
    broadcast.onNext(message);
    return Empty.getDefaultInstance();
}
 

@Mutation("seed")
Empty seed(
    ShelfServiceGrpc.ShelfServiceBlockingStub shelfClient,
    BookServiceGrpc.BookServiceBlockingStub bookClient) {

  String greatExpectations =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("Charles Dickens")
                          .setTitle("Great Expectations")
                          .setRead(false))
                  .build())
          .getId();
  String thinkingFastAndSlow =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("Daniel Kahnemann")
                          .setTitle("Thinking, Fast and Slow")
                          .setRead(true))
                  .build())
          .getId();
  String theCatcherInTheRye =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("J. D. Salinger")
                          .setTitle("The Catcher in the Rye")
                          .setRead(false))
                  .build())
          .getId();
  String huckleberryFinn =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("Mark Twain")
                          .setTitle("The Adventures of Huckleberry Finn")
                          .setRead(false))
                  .build())
          .getId();
  String masterAndMargarita =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("Mikhail Bulgakov")
                          .setTitle("The Master and Margarita")
                          .setRead(false))
                  .build())
          .getId();
  String warAndPeace =
      bookClient
          .createBook(
              CreateBookRequest.newBuilder()
                  .setBook(
                      Book.newBuilder()
                          .setAuthor("Leo Tolstoy")
                          .setTitle("War and Peace")
                          .setRead(true))
                  .build())
          .getId();

  shelfClient.createShelf(
      CreateShelfRequest.newBuilder()
          .setShelf(
              Shelf.newBuilder()
                  .setTheme("Satire")
                  .addAllBookIds(ImmutableList.of(greatExpectations, thinkingFastAndSlow))
                  .build())
          .build());
  shelfClient.createShelf(
      CreateShelfRequest.newBuilder()
          .setShelf(
              Shelf.newBuilder()
                  .setTheme("Classics")
                  .addAllBookIds(ImmutableList.of(theCatcherInTheRye, huckleberryFinn))
                  .build())
          .build());
  shelfClient.createShelf(
      CreateShelfRequest.newBuilder()
          .setShelf(
              Shelf.newBuilder()
                  .setTheme("Russian")
                  .addAllBookIds(ImmutableList.of(masterAndMargarita, warAndPeace))
                  .build())
          .build());
  return Empty.getDefaultInstance();
}
 

private MonoInvocation(MonoSink<Object> sink, Object[] args) {
    StreamObserver<Object> grpcStreamObserver = new ClientResponseObserver<Object, Object>() {
        @Override
        public void beforeStart(ClientCallStreamObserver requestStream) {
            sink.onCancel(() -> requestStream.cancel("React subscription cancelled", null));
        }

        @Override
        public void onNext(Object value) {
            if (emptyToVoidReply) {
                sink.success();
            } else {
                sink.success(value);
            }
        }

        @Override
        public void onError(Throwable error) {
            sink.error(error);
        }

        @Override
        public void onCompleted() {
            sink.success();
        }
    };

    Object[] grpcArgs = new Object[]{
            grpcArgPos < 0 ? Empty.getDefaultInstance() : args[grpcArgPos],
            grpcStreamObserver
    };

    GRPC_STUB invocationStub = handleCallMetadata(args)
            .withDeadline(Deadline.after(timeout.toMillis(), TimeUnit.MILLISECONDS));

    try {
        grpcMethod.invoke(invocationStub, grpcArgs);
    } catch (Exception e) {
        sink.error(e);
    }
}