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
28 package org.apache.hc.core5.http.nio.entity;
29
30 import java.io.IOException;
31 import java.util.Set;
32
33 import org.apache.hc.core5.annotation.Contract;
34 import org.apache.hc.core5.annotation.ThreadingBehavior;
35 import org.apache.hc.core5.http.nio.AsyncEntityProducer;
36 import org.apache.hc.core5.http.nio.DataStreamChannel;
37 import org.apache.hc.core5.util.Args;
38
39
40
41
42
43
44
45
46 @Contract(threading = ThreadingBehavior.IMMUTABLE_CONDITIONAL)
47 public class AsyncEntityProducerWrapper implements AsyncEntityProducer {
48
49 private final AsyncEntityProducer wrappedEntityProducer;
50
51 public AsyncEntityProducerWrapper(final AsyncEntityProducer wrappedEntityProducer) {
52 super();
53 this.wrappedEntityProducer = Args.notNull(wrappedEntityProducer, "Wrapped entity producer");
54 }
55
56 @Override
57 public boolean isRepeatable() {
58 return wrappedEntityProducer.isRepeatable();
59 }
60
61 @Override
62 public boolean isChunked() {
63 return wrappedEntityProducer.isChunked();
64 }
65
66 @Override
67 public long getContentLength() {
68 return wrappedEntityProducer.getContentLength();
69 }
70
71 @Override
72 public String getContentType() {
73 return wrappedEntityProducer.getContentType();
74 }
75
76 @Override
77 public String getContentEncoding() {
78 return wrappedEntityProducer.getContentEncoding();
79 }
80
81 @Override
82 public Set<String> getTrailerNames() {
83 return wrappedEntityProducer.getTrailerNames();
84 }
85
86 @Override
87 public int available() {
88 return wrappedEntityProducer.available();
89 }
90
91 @Override
92 public void produce(final DataStreamChannel channel) throws IOException {
93 wrappedEntityProducer.produce(channel);
94 }
95
96 @Override
97 public void failed(final Exception cause) {
98 wrappedEntityProducer.failed(cause);
99 }
100
101 @Override
102 public void releaseResources() {
103 wrappedEntityProducer.releaseResources();
104 }
105
106 @Override
107 public String toString() {
108 return "Wrapper [" + wrappedEntityProducer + "]";
109 }
110
111 }