code: func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor {
  	o := evaluateOptions(opts)
  	return func(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error {
  		if o.filterOutFunc != nil && !o.filterOutFunc(stream.Context(), info.FullMethod) {
  			return handler(srv, stream)
  		}
  		newCtx, serverSpan := newServerSpanFromInbound(stream.Context(), o.tracer, info.FullMethod)
  		wrappedStream := grpc_middleware.WrapServerStream(stream)
  		wrappedStream.WrappedContext = newCtx
  		err := handler(srv, wrappedStream)
  		finishServerSpan(newCtx, serverSpan, err)
  		return err
  	}
  }
docs: // StreamServerInterceptor returns a new streaming server interceptor for OpenTracing.