Class GrpcStreams

java.lang.Object
io.helidon.webserver.grpc.GrpcStreams
public final class GrpcStreams extends Object
Utilities used by generated declarative gRPC routes.

  • Method Summary

    Modifier and Type
    Method
    Description
    static <ReqT,ResT>
    io.grpc.stub.StreamObserver<ReqT>
    bidirectional(Function<Stream<ReqT>, Stream<ResT>> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
    Create a bidirectional request observer backed by a non-collecting request stream.
    static <ReqT,ResT>
    io.grpc.stub.StreamObserver<ReqT>
    clientStreaming(Function<Stream<ReqT>, ResT> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
    Create a client-streaming request observer backed by a non-collecting stream.
    static <ResT> void
    serverStreaming(Supplier<Stream<ResT>> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
    Send stream server-streaming responses.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • serverStreaming

      public static <ResT> void serverStreaming(Supplier<Stream<ResT>> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
      Send stream server-streaming responses.
      Type Parameters:
      ResT - response type
      Parameters:
      handler - endpoint handler
      responseObserver - response observer

    • clientStreaming

      public static <ReqT,ResT> io.grpc.stub.StreamObserver<ReqT> clientStreaming(Function<Stream<ReqT>, ResT> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
      Create a client-streaming request observer backed by a non-collecting stream.
      Type Parameters:
      ReqT - request type
      ResT - response type
      Parameters:
      handler - endpoint handler
      responseObserver - response observer
      Returns:
      request observer

    • bidirectional

      public static <ReqT,ResT> io.grpc.stub.StreamObserver<ReqT> bidirectional(Function<Stream<ReqT>, Stream<ResT>> handler, io.grpc.stub.StreamObserver<ResT> responseObserver)
      Create a bidirectional request observer backed by a non-collecting request stream.
      Type Parameters:
      ReqT - request type
      ResT - response type
      Parameters:
      handler - endpoint handler
      responseObserver - response observer
      Returns:
      request observer