@Override
  public <T> ResponseFuture<T> sendRequest(Request<T> request, RequestContext requestContext)
  {
    doEvaluateDisruptContext(request, requestContext);
    return _client.sendRequest(request, requestContext);
  }
@Test
  public void testDisruptSourceAlreadySet()
  {
    when(_context.getLocalAttr(eq(DISRUPT_SOURCE_KEY))).thenReturn(any(String.class));
    _client.sendRequest(_request, _context);
    verify(_context, never()).putLocalAttr(eq(DISRUPT_CONTEXT_KEY), any(String.class));
  }