Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 35 for onRead (0.04 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        override fun close() {
          if (closed) return
    
          if (bytesRemaining != 0L &&
            !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
          ) {
            carrier.noNewExchanges() // Unread bytes remain on the stream.
            responseBodyComplete(TRAILERS_RESPONSE_BODY_TRUNCATED)
          }
    
          closed = true
        }
      }
    
      /** An HTTP body with alternating chunk sizes and chunk bodies. */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  2. src/main/webapp/js/admin/plugins/form-validator/file.js

    "jpeg"):a.inArray("jpeg",c)>-1&&a.inArray("jpg",c)===-1&&c.push("jpg"),c},e=function(a,b,c,d){var e=d[b]||"";a.errorMessageKey="",a.errorMessage=e.replace("%s",c)},f=function(c,d,e){var f=new FileReader,g=new Image;f.readAsDataURL(c),f.onload=function(c){g.onload=function(){a(b).trigger("imageValidation",[this]),d(this)},g.onerror=function(){e()},g.src=c.target.result}};a.formUtils.addValidator({name:"mime",validatorFunction:function(b,f,g,h){if(c){var i=!0,j=f.get(0).files||[],k="",l=d(f);return...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 4.6K bytes
    - Click Count (0)
  3. internal/s3select/jstream/scanner.go

    					return
    				}
    			}
    
    			rpos += int64(n)
    			sr.fillReady <- int64(n)
    		}
    	}()
    
    	sr.fillReq <- struct{}{} // initial fill
    
    	return sr
    }
    
    // remaining returns the number of unread bytes
    // if EOF for the underlying reader has not yet been found,
    // maximum possible integer value will be returned
    func (s *scanner) remaining() int64 {
    	if atomic.LoadInt64(&s.end) == maxInt {
    		return maxInt
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  4. cmd/streaming-v4-unsigned.go

    }
    
    // Read - implements `io.Reader`, which transparently decodes
    // the incoming AWS Signature V4 streaming signature.
    func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {
    	// First, if there is any unread data, copy it to the client
    	// provided buffer.
    	if cr.offset > 0 {
    		n = copy(buf, cr.buffer[cr.offset:])
    		if n == len(buf) {
    			cr.offset += n
    			return n, nil
    		}
    		cr.offset = 0
    		buf = buf[n:]
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  5. src/archive/zip/reader.go

    	if r.err != nil {
    		return 0, r.err
    	}
    	n, err = r.rc.Read(b)
    	r.hash.Write(b[:n])
    	r.nread += uint64(n)
    	if r.nread > r.f.UncompressedSize64 {
    		return 0, ErrFormat
    	}
    	if err == nil {
    		return
    	}
    	if err == io.EOF {
    		if r.nread != r.f.UncompressedSize64 {
    			return 0, io.ErrUnexpectedEOF
    		}
    		if r.desr != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jan 15 18:35:56 GMT 2026
    - 28.5K bytes
    - Click Count (0)
  6. src/bytes/reader.go

    type Reader struct {
    	s        []byte
    	i        int64 // current reading index
    	prevRune int   // index of previous rune; or < 0
    }
    
    // Len returns the number of bytes of the unread portion of the
    // slice.
    func (r *Reader) Len() int {
    	if r.i >= int64(len(r.s)) {
    		return 0
    	}
    	return int(int64(len(r.s)) - r.i)
    }
    
    // Size returns the original length of the underlying byte slice.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jul 16 18:17:37 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

                        text.append(scanner.getFirst());
                        scanner.next();
                    }
                }
    
                visitor.onText(text.toString());
            }
            visitor.onEnd();
        }
    
        private void skipComment() {
            scanner.next(4);
            while (!scanner.isEmpty() && !scanner.lookingAt(END_HTML_COMMENT)) {
                scanner.next();
            }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Aug 19 15:07:24 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  8. src/bufio/bufio.go

    		}
    		b.fill() // buffer is empty
    	}
    	c := b.buf[b.r]
    	b.r++
    	b.lastByte = int(c)
    	return c, nil
    }
    
    // UnreadByte unreads the last byte. Only the most recently read byte can be unread.
    //
    // UnreadByte returns an error if the most recent method called on the
    // [Reader] was not a read operation. Notably, [Reader.Peek], [Reader.Discard], and [Reader.WriteTo] are not
    // considered read operations.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

                    "                <img src=\"https://fast.wistia.com/embed/medias/$2/swatch\" style=\"filter:blur(5px);height:100%;object-fit:contain;width:100%;\" alt=\"$1\" aria-hidden=\"true\" onload=\"this.parentNode.style.opacity=1;\" /> \n" +
                    "        </div></div></div></div> \n" +
                    "    </div> \n" +
                    "  </div> \n" +
                    "</details>");
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 03 01:59:51 GMT 2026
    - 11.3K bytes
    - Click Count (0)
  10. src/main/webapp/js/admin/plugins/form-validator/security.js

    row new Error("reCaptcha API can not be loaded by hand, delete reCaptcha API snippet.");if(!a.formUtils.hasLoadedGrecaptcha&&a('[data-validation~="recaptcha"]',c).length){a.formUtils.hasLoadedGrecaptcha=!0;var e="//www.google.com/recaptcha/api.js?onload=reCaptchaLoaded&render=explicit"+(d.lang?"&hl="+d.lang:""),f=document.createElement("script");f.type="text/javascript",f.async=!0,f.defer=!0,f.src=e,document.getElementsByTagName("body")[0].appendChild(f)}};b.reCaptchaLoaded=function(b){b&&"object"==typeof...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 10.5K bytes
    - Click Count (1)
Back to Top