code: func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor {
  	o := evaluateOptions(opts)
  	return func(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error) {
  		defer func() {
  			if r := recover(); r != nil {
  				err = recoverFrom(stream.Context(), r, o.recoveryHandlerFunc)
  			}
  		}()
  
  		return handler(srv, stream)
  	}
  }
docs: // StreamServerInterceptor returns a new streaming server interceptor for panic recovery.