output: #fixed code
                               @Override
  	public Flux<Payload> requestStream(Payload payload) {
  		RSocket service = findRSocket(payload);
  		return service.requestStream(payload);
  	}
input: #vulnerable code 
                               @Override
  	public Flux<Payload> requestStream(Payload payload) {
  		List<String> metadata = getRoutingMetadata(payload);
  		RSocket service = findRSocket(metadata);
  
  		if (service != null) {
  			return service.requestStream(payload);
  		}
  
  		MonoProcessor<RSocket> processor = MonoProcessor.create();
  		this.registry.pendingRequest(metadata, processor);
  
  		return processor
  				.log("pending-request")
  				.flatMapMany(rSocket -> rSocket.requestStream(payload));
  	} 
                              #location 11 
                              #vulnerability type NULL_DEREFERENCE