OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:onData
(Results
1 - 8
of
8
) sorted by null
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
PushObserver.java
32
* <li>{@link #
onData
} (optional sequence of data frames)</li>
70
boolean
onData
(int streamId, BufferedSource source, int byteCount, boolean last)
86
@Override public boolean
onData
(int streamId, BufferedSource source, int byteCount,
FramedConnection.java
890
boolean cancel = pushObserver.
onData
(streamId, buffer, byteCount, inFinished);
[
all
...]
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
PushObserver.java
33
* <li>{@link #
onData
} (optional sequence of data frames)</li>
72
boolean
onData
(int streamId, BufferedSource source, int byteCount, boolean last)
88
@Override public boolean
onData
(int streamId, BufferedSource source, int byteCount,
FramedConnection.java
895
boolean cancel = pushObserver.
onData
(streamId, buffer, byteCount, inFinished);
[
all
...]
/external/syzkaller/vendor/google.golang.org/grpc/transport/
flowcontrol.go
117
func (f *trInFlow)
onData
(n uint32) uint32 {
203
//
onData
is invoked when some data frame is received. It updates pendingData.
204
func (f *inFlow)
onData
(n uint32) error {
http2_server.go
561
if w := t.fc.
onData
(size); w > 0 {
584
if err := s.fc.
onData
(size); err != nil {
[
all
...]
http2_client.go
848
if w := t.fc.
onData
(size); w > 0 {
873
if err := s.fc.
onData
(size); err != nil {
[
all
...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
Http2ConnectionTest.java
508
@Override public boolean
onData
(int streamId, BufferedSource source, int byteCount,
544
@Override public synchronized boolean
onData
(
546
events.add(new AssertionError("
onData
"));
Completed in 700 milliseconds