1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 package org.apache.http.impl.nio;
28
29 import static org.junit.Assert.assertTrue;
30 import static org.mockito.Mockito.times;
31 import static org.mockito.Mockito.verify;
32
33 import java.nio.ByteBuffer;
34
35 import org.apache.http.nio.ContentDecoder;
36 import org.apache.http.nio.ContentDecoderChannel;
37 import org.apache.http.nio.ContentEncoder;
38 import org.apache.http.nio.ContentEncoderChannel;
39 import org.junit.After;
40 import org.junit.Before;
41 import org.junit.Test;
42 import org.mockito.Mock;
43 import org.mockito.MockitoAnnotations;
44
45 public class TestContentChannel {
46
47 @Mock private ContentDecoder decoder;
48 @Mock private ContentEncoder encoder;
49 @Mock private ByteBuffer bb;
50
51 @Before
52 public void setUp() throws Exception {
53 MockitoAnnotations.initMocks(this);
54 }
55
56 @After
57 public void tearDown() throws Exception {
58 }
59
60 @Test
61 public void testContentDecoder() throws Exception {
62 final ContentDecoderChannel cdc = new ContentDecoderChannel(decoder);
63
64 cdc.read(bb);
65 verify(decoder, times(1)).read(bb);
66
67 assertTrue(cdc.isOpen());
68
69 cdc.close();
70 }
71
72 @Test
73 public void testContentEncoder() throws Exception {
74 final ContentEncoderChannel cec = new ContentEncoderChannel(encoder);
75
76 cec.write(bb);
77 verify(encoder, times(1)).write(bb);
78
79 assertTrue(cec.isOpen());
80
81 cec.close();
82 }
83 }