running out of the wood--(she considered him to be a footman
because he was in livery:  otherwise, judging by his face only,
she would have called him a fish)--and rapped loudly at the door
with his knuckles.  It was opened by another footman in livery,
with a round face, and large eyes like a frog; and both footmen,
Alice noticed, had powdered hair that curled all over their

"contra", "cu", "cum", "cumva", "curând", "curînd", "da", "dă", "dacă", "dar", "datorită", "de", "deci", "deja", "deoarece", "departe", "deşi", "din", "dinaintea", "dintr", "dintre", "drept", "după", "ea", "ei", "el", "ele", "eram", "este", "eşti", "eu", "face", "fără", "fi", "fie", "fiecare", "fii", "fim", "fiţi", "iar", "ieri", "îi", "îl", "îmi", "împotriva", "în ", "înainte", "înaintea", "încât", "încît", "încotro", "între", "întrucât", "întrucît", "îţi", "la", "lângă", "le", "li", "lîngă", "lor", "lui",...

"contra", "cu", "cum", "cumva", "curând", "curînd", "da", "dă", "dacă", "dar", "datorită", "de", "deci", "deja", "deoarece", "departe", "deşi", "din", "dinaintea", "dintr", "dintre", "drept", "după", "ea", "ei", "el", "ele", "eram", "este", "eşti", "eu", "face", "fără", "fi", "fie", "fiecare", "fii", "fim", "fiţi", "iar", "ieri", "îi", "îl", "îmi", "împotriva", "în ", "înainte", "înaintea", "încât", "încît", "încotro", "între", "întrucât", "întrucît", "îţi", "la", "lângă", "le", "li", "lîngă", "lor", "lui",...

,EAAY7T,UAAUlC,OAAOqW,EAAsBC,GACnDP,EAAY7T,UAAUoQ,IAAIU,IAE1BrN,EAAczD,UAAUlC,OAAOgT,GAAmBsD,EAAgBD,GAElEhO,KAAKwL,YAAa,EAElBoC,EAAanD,GAAW,GAGYnN,EAAe0C,KAAKmO,eAEtDJ,GACF/N,KAAK6L,OAET,CAEAsC,cACE,OAAOnO,KAAKyF,SAAS5L,UAAUC,SAlUV,QAmUvB,CAEA4S,aACE,OAAOlG,EAAeG,QA9TGyH,wBA8T2BpO,KAAKyF,SAC3D,CAEA8G,YACE,OAAO/F,EAAetH,KAnUJ,iBAmUwBc,KAAKyF,SACjD,CAEAwG,iBACMjM,KAAKsL,YACP+C,cAAcrO,KAAKsL,WACnBtL,KAAKsL,UAAY,KAErB,CAEA2B,kBAAkBjD,GAChB,OAAIjP,IACKiP,IAAcO,GAAiBD,GAAaD,EAG9CL,IAAcO,GAAiBF,EAAaC,E...

                this.similarDocHash = similarDocHash;
            }
            return this;
        }

        /**
         * Sets the facet information for aggregations.
         *
         * @param facetInfo the facet configuration
         * @return this builder for method chaining
         */
        public SearchConditionBuilder facetInfo(final FacetInfo facetInfo) {

AAK,4BACLC,KAAM,mCAEVZ,SAAU,CACNC,QAAS,0DACTC,QAAS,oDACTE,QAAS,8CACTD,SAAU,SAAU6G,GAChB,GAAIA,EAAIzK,SAAWpR,KAAKoR,OAcpB,OAAmB,IAAfpR,KAAKqT,MACE,mCAEA,6BAhBX,OAAQrT,KAAKqT,OACT,KAAK,EACD,MAAO,oFACX,KAAK,EACL,KAAK,EACL,KAAK,EACD,MAAO,oFACX,KAAK,EACL,KAAK,EACL,KAAK,EACD,MAAO,sFAUvB6B,SAAU,SAAU2G,GAChB,GAAIA,EAAIzK,SAAWpR,KAAKoR,OAcpB,OAAmB,IAAfpR,KAAKqT,MACE,mCAEA,6BAhBX,OAAQrT,KAAKqT,OACT,KAAK,EACD,MAAO,wEACX,KAAK,EACL,KAAK,EACL,KAAK,EACD,MAAO,wEACX,KAAK,EACL,KAAK,EACL,KAAK,EACD,MAAO,0EAUvB8B,SA...

    /** The key of the message: Min Error Count */
    public static final String LABELS_ERROR_COUNT_MIN = "{labels.errorCountMin}";

    /** The key of the message: Facet */
    public static final String LABELS_FACET = "{labels.facet}";

    /** The key of the message: Geo */
    public static final String LABELS_GEO = "{labels.geo}";

    /** The key of the message: Groups */

    assertContent("Body", response)
    response.close()
    assertThat(server.requestCount).isEqualTo(2)
  }

  @Test
  fun readTimeouts() {
    // This relies on the fact that MockWebServer doesn't close the
    // connection after a response has been sent. This causes the client to
    // try to read more bytes than are sent, which results in a timeout.
    server.enqueue(

nB,GAAOV,KAAMN,GAGtB,OAAkB,IAAbV,GAA+B,KAAbA,EACfkC,EAAKqD,YAEK,IAAbvF,EACGkC,EAAKsD,gBAAgBD,YAEX,IAAbvF,GAA+B,IAAbA,EACfkC,EAAKuD,UAKN5C,GAIR6C,UAAW,SAAU/G,EAAKgH,GACzB,IAAI9C,EAAM8C,GAAW,GAarB,OAXY,MAAPhH,IACCoD,EAAalD,OAAQF,IACzB+C,GAAOoB,MAAOD,EACE,iBAARlE,EACN,CAAEA,GAAQA,GAGZU,EAAKH,KAAM2D,EAAKlE,IAIXkE,GAGR+C,QAAS,SAAU1D,EAAMvD,EAAKiC,GAC7B,OAAc,MAAPjC,GAAe,EAAIW,GAAQJ,KAAMP,EAAKuD,EAAMtB,IAGpDiF,SAAU,SAAU3D,GACnB,IAAI4D,EAAY5D,GAAQA,EAAK6D,aAC5BC,EAAU9D,IAAUA,EAAK+D,eAAiB/D,GAAOsD,gBAIlD...

  }

  @Test
  fun canceledBeforeResponseReadSignalsOnFailure_HTTP_2() {
    enableProtocol(Protocol.HTTP_2)
    canceledBeforeResponseReadSignalsOnFailure()
  }

  /**
   * There's a race condition where the cancel may apply after the stream has already been
   * processed.
   */
  @Test
  fun canceledAfterResponseIsDeliveredBreaksStreamButSignalsOnce() {
    server.enqueue(MockResponse(body = "A"))