OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
defs:endOfStream
(Results
1 - 10
of
10
) sorted by null
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
SendResponseHeadersCommand.java
56
boolean
endOfStream
() {
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
AbstractServerStream.java
119
WritableBuffer frame, boolean
endOfStream
, boolean flush, int numMessages) {
120
// Since
endOfStream
is triggered by the sending of trailers, avoid flush here and just flush
122
abstractServerStreamSink().writeFrame(frame,
endOfStream
? false : flush, numMessages);
194
private boolean
endOfStream
= false;
231
if (
endOfStream
) {
261
* @param
endOfStream
{@code true} if no more data will be received on the stream.
263
public void inboundDataReceived(ReadableBuffer frame, boolean
endOfStream
) {
264
Preconditions.checkState(!this.
endOfStream
, "Past end of stream");
267
if (
endOfStream
) {
268
this.
endOfStream
= true
[
all
...]
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
OkHttpClientStream.java
150
WritableBuffer frame, boolean
endOfStream
, boolean flush, int numMessages) {
163
state.sendBuffer(buffer,
endOfStream
, flush);
235
outboundFlow.data(data.
endOfStream
, id, data.buffer, false);
297
public void transportHeadersReceived(List<Header> headers, boolean
endOfStream
) {
298
if (
endOfStream
) {
309
public void transportDataReceived(okio.Buffer frame, boolean
endOfStream
) {
323
super.transportDataReceived(new OkHttpReadableBuffer(frame),
endOfStream
);
362
private void sendBuffer(Buffer buffer, boolean
endOfStream
, boolean flush) {
368
pendingData.add(new PendingData(buffer,
endOfStream
, flush));
373
outboundFlow.data(
endOfStream
, id(), buffer, flush)
[
all
...]
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
CronetClientStream.java
165
WritableBuffer buffer, boolean
endOfStream
, boolean flush, int numMessages) {
179
state.enqueuePendingData(new PendingData(byteBuffer,
endOfStream
, flush));
181
streamWrite(byteBuffer,
endOfStream
, flush);
280
private void transportHeadersReceived(Metadata metadata, boolean
endOfStream
) {
281
if (
endOfStream
) {
289
private void transportDataReceived(ByteBuffer buffer, boolean
endOfStream
) {
291
super.transportDataReceived(ReadableBuffers.wrap(buffer),
endOfStream
);
310
streamWrite(data.buffer, data.
endOfStream
, data.flush);
347
private void streamWrite(ByteBuffer buffer, boolean
endOfStream
, boolean flush) {
351
stream.write(buffer,
endOfStream
);
[
all
...]
/external/grpc-grpc-java/netty/shaded/
grpc-netty-shaded-1.14.0.jar
/external/guice/extensions/persist/lib/
oro-2.0.8.jar
/external/grpc-grpc-java/core/
grpc-core-1.14.0.jar
/external/guice/extensions/struts2/lib/
ant-1.6.5.jar
/external/jarjar/lib/
apache-ant-1.9.4.jar
/external/owasp/sanitizer/tools/findbugs/lib/
ant.jar
Completed in 1954 milliseconds