I am trying to implement a stream server interceptor in Go, and its job is to reject the RPC (and therefore close the stream) if the client didn’t provide a certain header.

I want to proxy all RPC methods of an existing, established gRPC client connection on a gRPC Go server.

I have a unit test that is similar to the following (adapted from https://github.com/castaneai/grpc-testing-with-bufconn/blob/master/server/server.go):