本文整理了Java中okio.Buffer.clear()方法的一些代码示例，展示了Buffer.clear()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Buffer.clear()方法的具体详情如下：
包路径：okio.Buffer
类名称：Buffer
方法名：clear
[英]Discards all bytes in this buffer. Calling this method when you're done with a buffer will return its segments to the pool.
[中]丢弃此缓冲区中的所有字节。处理完缓冲区后调用此方法会将其段返回到池中。
代码示例来源：origin: square/wire
public final Builder<M, B> clearUnknownFields() {
unknownFieldsByteString = ByteString.EMPTY;
if (unknownFieldsBuffer != null) {
unknownFieldsBuffer.clear();
unknownFieldsBuffer = null;
}
unknownFieldsWriter = null;
return this;
}代码示例来源：origin: square/okio
@Override public void close() throws IOException {
if (closed) return;
closed = true;
markBuffer.clear();
super.close();
}
}代码示例来源：origin: square/moshi
@Override public void close() throws IOException {
peeked = PEEKED_NONE;
scopes[0] = JsonScope.CLOSED;
stackSize = 1;
buffer.clear();
source.close();
}代码示例来源：origin: apollographql/apollo-android
@Override public void close() throws IOException {
peeked = PEEKED_NONE;
stack[0] = JsonScope.CLOSED;
stackSize = 1;
buffer.clear();
source.close();
}代码示例来源：origin: square/okhttp
@Override public void close() throws IOException {
long bytesDiscarded;
synchronized (Http2Stream.this) {
closed = true;
bytesDiscarded = readBuffer.size();
readBuffer.clear();
Http2Stream.this.notifyAll(); // TODO(jwilson): Unnecessary?
}
if (bytesDiscarded > 0) {
updateConnectionFlowControl(bytesDiscarded);
}
cancelStreamIfNecessary();
}
}代码示例来源：origin: square/okio
/** Resets {@linkplain #source() the source} to {@code userOffset}. */
public void reset(long userOffset) throws IOException {
if (closed) {
throw new IllegalStateException("closed");
}
if (userOffset < mark // userOffset is before mark.
|| userOffset > limit // userOffset is beyond limit.
|| userOffset > mark + markBuffer.size() // userOffset is in the future.
|| offset - userBuffer.size() > limit) { // Stream advanced beyond limit.
throw new IOException("cannot reset to " + userOffset + ": out of range");
}
// Clear userBuffer to cause data at 'offset' to be returned by the next read.
offset = userOffset;
userBuffer.clear();
}代码示例来源：origin: square/okhttp
/**
* Either writes this request to {@code sink} or measures its content length. We have one method
* do double-duty to make sure the counting and content are consistent, particularly when it comes
* to awkward operations like measuring the encoded length of header strings, or the
* length-in-digits of an encoded integer.
*/
private long writeOrCountBytes(@Nullable BufferedSink sink, boolean countBytes) {
long byteCount = 0L;
Buffer buffer;
if (countBytes) {
buffer = new Buffer();
} else {
buffer = sink.buffer();
}
for (int i = 0, size = encodedNames.size(); i < size; i++) {
if (i > 0) buffer.writeByte('&');
buffer.writeUtf8(encodedNames.get(i));
buffer.writeByte('=');
buffer.writeUtf8(encodedValues.get(i));
}
if (countBytes) {
byteCount = buffer.size();
buffer.clear();
}
return byteCount;
}代码示例来源：origin: com.squareup.okhttp3/okhttp
@Override public void close() throws IOException {
long bytesDiscarded;
synchronized (Http2Stream.this) {
closed = true;
bytesDiscarded = readBuffer.size();
readBuffer.clear();
Http2Stream.this.notifyAll(); // TODO(jwilson): Unnecessary?
}
if (bytesDiscarded > 0) {
updateConnectionFlowControl(bytesDiscarded);
}
cancelStreamIfNecessary();
}
}代码示例来源：origin: square/okhttp
/**
* Reads until {@code in} is exhausted or the deadline has been reached. This is careful to not
* extend the deadline if one exists already.
*/
public static boolean skipAll(Source source, int duration, TimeUnit timeUnit) throws IOException {
long now = System.nanoTime();
long originalDuration = source.timeout().hasDeadline()
? source.timeout().deadlineNanoTime() - now
: Long.MAX_VALUE;
source.timeout().deadlineNanoTime(now + Math.min(originalDuration, timeUnit.toNanos(duration)));
try {
Buffer skipBuffer = new Buffer();
while (source.read(skipBuffer, 8192) != -1) {
skipBuffer.clear();
}
return true; // Success! The source has been exhausted.
} catch (InterruptedIOException e) {
return false; // We ran out of time before exhausting the source.
} finally {
if (originalDuration == Long.MAX_VALUE) {
source.timeout().clearDeadline();
} else {
source.timeout().deadlineNanoTime(now + originalDuration);
}
}
}代码示例来源：origin: com.squareup.okhttp3/okhttp
/**
* Either writes this request to {@code sink} or measures its content length. We have one method
* do double-duty to make sure the counting and content are consistent, particularly when it comes
* to awkward operations like measuring the encoded length of header strings, or the
* length-in-digits of an encoded integer.
*/
private long writeOrCountBytes(@Nullable BufferedSink sink, boolean countBytes) {
long byteCount = 0L;
Buffer buffer;
if (countBytes) {
buffer = new Buffer();
} else {
buffer = sink.buffer();
}
for (int i = 0, size = encodedNames.size(); i < size; i++) {
if (i > 0) buffer.writeByte('&');
buffer.writeUtf8(encodedNames.get(i));
buffer.writeByte('=');
buffer.writeUtf8(encodedValues.get(i));
}
if (countBytes) {
byteCount = buffer.size();
buffer.clear();
}
return byteCount;
}代码示例来源：origin: square/okio
markBuffer.clear();
mark = -1L;
limit = -1L;代码示例来源：origin: com.squareup.okhttp3/okhttp
/**
* Reads until {@code in} is exhausted or the deadline has been reached. This is careful to not
* extend the deadline if one exists already.
*/
public static boolean skipAll(Source source, int duration, TimeUnit timeUnit) throws IOException {
long now = System.nanoTime();
long originalDuration = source.timeout().hasDeadline()
? source.timeout().deadlineNanoTime() - now
: Long.MAX_VALUE;
source.timeout().deadlineNanoTime(now + Math.min(originalDuration, timeUnit.toNanos(duration)));
try {
Buffer skipBuffer = new Buffer();
while (source.read(skipBuffer, 8192) != -1) {
skipBuffer.clear();
}
return true; // Success! The source has been exhausted.
} catch (InterruptedIOException e) {
return false; // We ran out of time before exhausting the source.
} finally {
if (originalDuration == Long.MAX_VALUE) {
source.timeout().clearDeadline();
} else {
source.timeout().deadlineNanoTime(now + originalDuration);
}
}
}代码示例来源：origin: square/okhttp
} else if (countBytes) {
byteCountBuffer.clear();
return -1L;
byteCountBuffer.clear();代码示例来源：origin: square/okio
@Override public ByteString call() throws Exception {
Buffer blackhole = new Buffer();
HashingSink hashingSink = HashingSink.sha1(blackhole);
Buffer buffer = new Buffer();
while (pipe.source().read(buffer, Long.MAX_VALUE) != -1) {
hashingSink.write(buffer, buffer.size());
blackhole.clear();
}
pipe.source().close();
return hashingSink.hash();
}
});代码示例来源：origin: com.squareup.okhttp3/okhttp
} else if (countBytes) {
byteCountBuffer.clear();
return -1L;
byteCountBuffer.clear();代码示例来源：origin: huxq17/SwipeCardsView
@Override public void close() throws IOException {
synchronized (FramedStream.this) {
closed = true;
readBuffer.clear();
FramedStream.this.notifyAll();
}
cancelStreamIfNecessary();
}代码示例来源：origin: duzechao/OKHttpUtils
@Override public void close() throws IOException {
synchronized (FramedStream.this) {
closed = true;
readBuffer.clear();
FramedStream.this.notifyAll();
}
cancelStreamIfNecessary();
}代码示例来源：origin: com.github.ljun20160606/okhttp
@Override public void close() throws IOException {
synchronized (Http2Stream.this) {
closed = true;
readBuffer.clear();
Http2Stream.this.notifyAll();
}
cancelStreamIfNecessary();
}代码示例来源：origin: com.amazonaws/aws-android-sdk-appsync-runtime
@Override public void close() throws IOException {
peeked = PEEKED_NONE;
stack[0] = JsonScope.CLOSED;
stackSize = 1;
buffer.clear();
source.close();
}代码示例来源：origin: com.squareup.moshi/moshi
@Override public void close() throws IOException {
peeked = PEEKED_NONE;
scopes[0] = JsonScope.CLOSED;
stackSize = 1;
buffer.clear();
source.close();
}内容来源于网络，如有侵权，请联系作者删除！