Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for writeHeader (0.06 sec)

  1. cmd/peer-rest-server.go

    		case <-ctx.Done():
    			return grid.NewRemoteErr(ctx.Err())
    		}
    	}
    }
    
    func (s *peerRESTServer) writeErrorResponse(w http.ResponseWriter, err error) {
    	w.WriteHeader(http.StatusForbidden)
    	w.Write([]byte(err.Error()))
    }
    
    // IsValid - To authenticate and verify the time difference.
    func (s *peerRESTServer) IsValid(w http.ResponseWriter, r *http.Request) bool {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    	return nil
    }
    
    func (w *testResponseWriter) Write(p []byte) (int, error) {
    	w.response = append(w.response, p...)
    	return len(p), nil
    }
    
    func (w *testResponseWriter) WriteHeader(statusCode int) {
    	w.statusCode = statusCode
    }
    
    func (w *testResponseWriter) Flush() {
    }
    
    func TestJSONQueries(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

            }
    
            @Override
            public HighlightInfo getHighlightInfo() {
                return new HighlightInfo();
            }
        }
    
        @Override
        protected void writeHeaders(final HttpServletResponse response) {
            ComponentUtil.getFessConfig().getApiJsonResponseHeaderList().forEach(e -> response.setHeader(e.getFirst(), e.getSecond()));
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 55.4K bytes
    - Viewed (1)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Play it back.
        val connection = connect(peer)
        connection.writePingAndAwaitPong()
        val stream = connection.newStream(headerEntries("a", "android"), true)
        // finish the stream
        stream.writeHeaders(headerEntries("b", "berserk"), true, false)
        assertFailsWith<IllegalStateException> {
          stream.enqueueTrailers(headersOf("trailers", "boom"))
        }
      }
    
      @Test fun noTrailersFrameYieldsEmptyTrailers() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
Back to top