code: func PayloadStreamClientInterceptor(entry *logrus.Entry, decider grpc_logging.ClientPayloadLoggingDecider) grpc.StreamClientInterceptor {
  	return func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) {
  		if !decider(ctx, method) {
  			return streamer(ctx, desc, cc, method, opts...)
  		}
  		logEntry := entry.WithFields(newClientLoggerFields(ctx, method))
  		clientStream, err := streamer(ctx, desc, cc, method, opts...)
  		newStream := &loggingClientStream{ClientStream: clientStream, entry: logEntry}
  		return newStream, err
  	}
  }
docs: // PayloadStreamClientInterceptor returns a new streaming client interceptor that logs the paylods of requests and responses.