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.io.entity;
29
30 import java.io.IOException;
31 import java.io.InputStream;
32
33 import org.apache.hc.core5.annotation.Contract;
34 import org.apache.hc.core5.annotation.ThreadingBehavior;
35 import org.apache.hc.core5.http.ContentType;
36 import org.apache.hc.core5.io.Closer;
37 import org.apache.hc.core5.util.Args;
38
39
40
41
42
43
44 @Contract(threading = ThreadingBehavior.IMMUTABLE_CONDITIONAL)
45 public class BasicHttpEntity extends AbstractHttpEntity {
46
47 private final InputStream content;
48 private final long length;
49
50 public BasicHttpEntity(
51 final InputStream content, final long length, final ContentType contentType, final String contentEncoding,
52 final boolean chunked) {
53 super(contentType, contentEncoding, chunked);
54 this.content = Args.notNull(content, "Content stream");
55 this.length = length;
56 }
57
58 public BasicHttpEntity(
59 final InputStream content, final long length, final ContentType contentType, final String contentEncoding) {
60 this(content, length, contentType, contentEncoding, false);
61 }
62
63 public BasicHttpEntity(final InputStream content, final long length, final ContentType contentType) {
64 this(content, length, contentType, null);
65 }
66
67 public BasicHttpEntity(final InputStream content, final ContentType contentType, final String contentEncoding) {
68 this(content, -1, contentType, contentEncoding);
69 }
70
71 public BasicHttpEntity(final InputStream content, final ContentType contentType) {
72 this(content, -1, contentType, null);
73 }
74
75 public BasicHttpEntity(final InputStream content, final ContentType contentType, final boolean chunked) {
76 this(content, -1, contentType, null, chunked);
77 }
78
79 @Override
80 public final long getContentLength() {
81 return this.length;
82 }
83
84 @Override
85 public final InputStream getContent() throws IllegalStateException {
86 return this.content;
87 }
88
89 @Override
90 public final boolean isRepeatable() {
91 return false;
92 }
93
94 @Override
95 public final boolean isStreaming() {
96 return this.content != null && this.content != EmptyInputStream.INSTANCE;
97 }
98
99 @Override
100 public final void close() throws IOException {
101 Closer.close(content);
102 }
103
104 }