HomeSort by relevance Sort by last modified time
    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