NO EVENT SHALL THE COPYRIGHT L21:OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, L22:SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT L23:LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, L24:DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY L25:THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT L26:(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE L27:OF THIS SOFTWARE, EVEN IF ADVISED...

PURPOSE ARE DISCLAIMED. L19:IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY DIRECT, INDIRECT, L20:INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT L21:NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, L22:DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY L23:THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT L24:(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF L25:THIS SOFTWARE, EVEN IF ADVISED...

limitations under the License. L15: */ L16:package okhttp3.internal.http2 L17: L18:import assertk.fail L19:import okio.BufferedSource L20:import okio.ByteString L21: L22:internal open class BaseTestHandler : Http2Reader.Handler { L23: override fun data( L24: inFinished: Boolean, L25: streamId: Int, L26: source: BufferedSource, L27: length: Int, L28: ) { L29: fail("") L30: } L31: L32: override fun headers( L33: inFinished: Boolean, L34: streamId: Int, L35: associatedStreamId:...

============== L60: @Execute L61: @Secured({ ROLE, ROLE + VIEW }) L62: public HtmlResponse index() { L63: return asHtml(path_AdminDict_AdminDictJsp).renderWith(data -> { L64: final DictionaryFile<? extends DictionaryItem>[] dictFiles = dictionaryManager.getDictionaryFiles(); L65: RenderDataUtil.register(data, "dictFiles", dictFiles); L66: }); L67: } L68:}...

L205: L206: /** L207: * Returns a new {@link CharSource} for reading character data from the given file using the given L208: * character set. L209: * L210: * @since 14.0 L211: */ L212: public static CharSource asCharSource(File file, Charset charset) { L213: return asByteSource(file).asCharSource(charset); L214: } L215: L216: /** L217: * Returns a new {@link CharSink} for writing character data to the given file using the given L218: * character set. The given {@code modes}...

LineReader}. Line separators are per {@link java.io.BufferedReader}: line feed, carriage return, L25: * or carriage return followed immediately by a linefeed. L26: * L27: * <p>Subclasses must implement {@link #handleLine}, call {@link #add} to pass character data, and L28: * call {@link #finish} at the end of stream. L29: * L30: * @author Chris Nokleberg L31: * @since 1.0 L32: */ L33:@J2ktIncompatible L34:@GwtIncompatible L35:@ElementTypesAreNonnullByDefault L36:abstract class LineBuffer { L37: /** Holds partial...

LineReader}. Line separators are per {@link java.io.BufferedReader}: line feed, carriage return, L25: * or carriage return followed immediately by a linefeed. L26: * L27: * <p>Subclasses must implement {@link #handleLine}, call {@link #add} to pass character data, and L28: * call {@link #finish} at the end of stream. L29: * L30: * @author Chris Nokleberg L31: * @since 1.0 L32: */ L33:@J2ktIncompatible L34:@GwtIncompatible L35:@ElementTypesAreNonnullByDefault L36:abstract class LineBuffer { L37: /** Holds partial...

L45: } L46: L47: @AfterEach L48: fun after() { L49: listener.assertExhausted() L50: } L51: L52: @Test L53: fun processResponse() { L54: server.enqueue( L55: MockResponse.Builder() L56: .body( L57: """ L58: |data: hey L59: | L60: | L61: """.trimMargin(), L62: ).setHeader("content-type", "text/event-stream") L63: .build(), L64: ) L65: val request = L66: Request.Builder() L67: .url(server.url("/")) L68:...

WebFsIndexSize=Index size (Web/File system) L480:labels.crawling_info_DataCrawlExecTime=Crawl exec time (Data store) L481:labels.crawling_info_DataCrawlStartTime=Crawl start time (Data store) L482:labels.crawling_info_DataCrawlEndTime=Crawl end time (Data store) L483:labels.crawling_info_DataIndexExecTime=Indexing exec time (Data store) L484:labels.crawling_info_DataIndexSize=Index size (Data store) L485:labels.webauth_configuration=Web Authentication L486:labels.webauth_list_hostname=Hostname L...

If `chain.proceed(request)` is being called more than once previous response bodies must be closed. L27: L28:Interceptors can be chained. Suppose you have both a compressing interceptor and a checksumming interceptor: you'll need to decide whether data is compressed and then checksummed, or checksummed and then compressed. OkHttp uses lists to track interceptors, and interceptors are called in order. L29: L30: L31: L32:### Application Interceptors...