Source File
	grpcprocess.go

Belonging Package
	go.pact.im/x/grpcprocess

// Package grpcprocess provides [process.Runner] wrapper for [grpc.Server].
package grpcprocess

import (
	"context"
	"net"

	"google.golang.org/grpc"

	"go.pact.im/x/process"
)

// Server returns a [process.Runner] instance for the given gRPC server and
// network listener.
func Server(srv *grpc.Server, lis net.Listener) process.Runner {
	return process.Leaf(
		func(_ context.Context) error {
			// TODO: consider injecting base context into gRPC’s
			// internal/transport/http2_server.go NewServerTransport.
			return srv.Serve(lis)
		},
		func(ctx context.Context) error {
			done := make(chan struct{})
			go func() {
				srv.GracefulStop()
				close(done)
			}()
			select {
			case <-ctx.Done():
				// Note that Stop interrupts GracefulStop when
				// called concurrently.
				srv.Stop()
				<-done
			case <-done:
			}
			return nil
		},
	)
}

The pages are generated with Golds v0.7.6. (GOOS=linux GOARCH=amd64)