Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for FlushError (0.1 sec)

  1. src/net/http/responsecontroller.go

    	Unwrap() ResponseWriter
    }
    
    // Flush flushes buffered data to the client.
    func (c *ResponseController) Flush() error {
    	rw := c.rw
    	for {
    		switch t := rw.(type) {
    		case interface{ FlushError() error }:
    			return t.FlushError()
    		case Flusher:
    			t.Flush()
    			return nil
    		case rwUnwrapper:
    			rw = t.Unwrap()
    		default:
    			return errNotSupported()
    		}
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. src/net/http/server.go

    }
    
    func (w *response) closedRequestBodyEarly() bool {
    	body, ok := w.req.Body.(*body)
    	return ok && body.didEarlyClose()
    }
    
    func (w *response) Flush() {
    	w.FlushError()
    }
    
    func (w *response) FlushError() error {
    	if !w.wroteHeader {
    		w.WriteHeader(StatusOK)
    	}
    	err := w.w.Flush()
    	e2 := w.cw.flush()
    	if err == nil {
    		err = e2
    	}
    	return err
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  3. src/net/http/h2_bundle.go

    		} else {
    			st.writeDeadline.Reset(deadline.Sub(sc.srv.now()))
    		}
    	})
    	return nil
    }
    
    func (w *http2responseWriter) Flush() {
    	w.FlushError()
    }
    
    func (w *http2responseWriter) FlushError() error {
    	rws := w.rws
    	if rws == nil {
    		panic("Header called after Handler finished")
    	}
    	var err error
    	if rws.bw.Buffered() > 0 {
    		err = rws.bw.Flush()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
Back to top