1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.rest.filter.GZIPResponseStream

Java 类org.apache.hadoop.hbase.rest.filter.GZIPResponseStream 实例源码

项目：ditb    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(wrapper.getWriter());
}
项目：ditb    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  verify(response).addHeader("Content-Encoding", "gzip");
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：LCIndex-HBase-0.94.16    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  HttpServletResponse response = mock(HttpServletResponse.class);
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);
  GZIPResponseWrapper test = new GZIPResponseWrapper(response);

  ServletOutputStream servletOutput = test.getOutputStream();
  assertEquals(org.apache.hadoop.hbase.rest.filter.GZIPResponseStream.class,
      servletOutput.getClass());
  test.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = test.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(test.getWriter());

}
项目：LCIndex-HBase-0.94.16    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  HttpServletResponse response = mock(HttpServletResponse.class);
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);
  GZIPResponseWrapper test = new GZIPResponseWrapper(response);

  ServletOutputStream servletOutput = test.getOutputStream();
  assertEquals(org.apache.hadoop.hbase.rest.filter.GZIPResponseStream.class,
      servletOutput.getClass());
  test.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = test.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：HIndex    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(wrapper.getWriter());
}
项目：HIndex    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  verify(response).addHeader("Content-Encoding", "gzip");
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：IRIndex    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  HttpServletResponse response = mock(HttpServletResponse.class);
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);
  GZIPResponseWrapper test = new GZIPResponseWrapper(response);

  ServletOutputStream servletOutput = test.getOutputStream();
  assertEquals(org.apache.hadoop.hbase.rest.filter.GZIPResponseStream.class,
      servletOutput.getClass());
  test.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = test.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(test.getWriter());

}
项目：IRIndex    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  HttpServletResponse response = mock(HttpServletResponse.class);
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);
  GZIPResponseWrapper test = new GZIPResponseWrapper(response);

  ServletOutputStream servletOutput = test.getOutputStream();
  assertEquals(org.apache.hadoop.hbase.rest.filter.GZIPResponseStream.class,
      servletOutput.getClass());
  test.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = test.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：hbase    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(wrapper.getWriter());
}
项目：hbase    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  verify(response).addHeader("Content-Encoding", "gzip");
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：PyroDB    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(wrapper.getWriter());
}
项目：PyroDB    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  verify(response).addHeader("Content-Encoding", "gzip");
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：c5    文件：TestGZIPResponseWrapper.java    
@Test
public void testResetBuffer() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.resetBuffer();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
  assertNotNull(wrapper.getWriter());
}
项目：c5    文件：TestGZIPResponseWrapper.java    
@Test
public void testReset() throws IOException {
  when(response.isCommitted()).thenReturn(false);
  ServletOutputStream out = mock(ServletOutputStream.class);
  when(response.getOutputStream()).thenReturn(out);

  ServletOutputStream servletOutput = wrapper.getOutputStream();
  verify(response).addHeader("Content-Encoding", "gzip");
  assertEquals(GZIPResponseStream.class, servletOutput.getClass());
  wrapper.reset();
  verify(response).setHeader("Content-Encoding", null);

  when(response.isCommitted()).thenReturn(true);
  servletOutput = wrapper.getOutputStream();
  assertEquals(out.getClass(), servletOutput.getClass());
}
项目：LCIndex-HBase-0.94.16    文件：TestGZIPResponseWrapper.java    
@Test
public void testGZIPResponseStream() throws IOException {
  HttpServletResponse httpResponce = mock(HttpServletResponse.class);
  ServletOutputStream out = mock(ServletOutputStream.class);

  when(httpResponce.getOutputStream()).thenReturn(out);
  GZIPResponseStream test = new GZIPResponseStream(httpResponce);
  verify(httpResponce).addHeader("Content-Encoding", "gzip");

  test.close();

  test.resetBuffer();
  verify(httpResponce).setHeader("Content-Encoding", null);
}
项目：IRIndex    文件：TestGZIPResponseWrapper.java    
@Test
public void testGZIPResponseStream() throws IOException {
  HttpServletResponse httpResponce = mock(HttpServletResponse.class);
  ServletOutputStream out = mock(ServletOutputStream.class);

  when(httpResponce.getOutputStream()).thenReturn(out);
  GZIPResponseStream test = new GZIPResponseStream(httpResponce);
  verify(httpResponce).addHeader("Content-Encoding", "gzip");

  test.close();

  test.resetBuffer();
  verify(httpResponce).setHeader("Content-Encoding", null);
}