process it. L17: L18: This change may increase OkHttp's memory use for applications that make many concurrent HTTP L19: calls and that can receive data faster than they can process it. Previously, OkHttp limited L20: HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB L21: of unacknowledged data per stream and no per-connection limit. L22: L23: * Fix: Don't operate on a connection after it's been returned to the pool. This race occurred L24:...

limitations under the License. L15: */ L16:package mockwebserver3 L17: L18:import okhttp3.ExperimentalOkHttpApi L19: L20:/** L21: * Handles a call's stream directly. Use this instead of [MockResponseBody] to begin sending L22: * response data before all request data has been received. L23: * L24: * See [okhttp3.RequestBody.isDuplex]. L25: */ L26:@ExperimentalOkHttpApi L27:interface StreamHandler { L28: fun handle(stream: Stream) L29:}...

key="labels.searchoptions_menu_num" /> <a L60: href="#searchOptions" class="badge badge-primary" L61: data-toggle="control-options"> <la:message L62: key="labels.searchoptions_num" arg0="${f:h(num)}" /> L63: </a></li> L64: <li class="list-inline-item"><la:message key="labels.searchoptions_menu_lang" /> <a L65: href="#searchOptions" class="badge badge-primary" L66: data-toggle="control-options"> <c:if test="${empty lang}"> L67: <la:message key="labels.searchoptions_all" />...

key="labels.searchoptions_menu_num" /> <a L60: href="#searchOptions" class="badge badge-primary" L61: data-toggle="control-options"> <la:message L62: key="labels.searchoptions_num" arg0="${f:h(num)}" /> L63: </a></li> L64: <li class="list-inline-item"><la:message key="labels.searchoptions_menu_lang" /> <a L65: href="#searchOptions" class="badge badge-primary" L66: data-toggle="control-options"> <c:if test="${empty lang}"> L67: <la:message key="labels.searchoptions_all" />...

.empty.list.count=3600 L280:indexer.webfs.update.interval=10000 L281:indexer.webfs.max.document.cache.size=10 L282:indexer.webfs.max.document.request.size=1048576 L283:indexer.data.max.document.cache.size=10000 L284:indexer.data.max.document.request.size=1048576 L285:indexer.data.max.delete.cache.size=100 L286:indexer.data.max.redirect.count=10 L287:indexer.language.fields=content,important_content,title L288:indexer.language.detect.length=1000 L289:indexer.max.result.window.size=10000 L290:inde...

wler_index"/> L125: </h3> L126: </div> L127: <div class="card-footer"> L128: <button type="button" class="btn btn-danger" data-toggle="modal" data-target="#confirmToClearCrawlerIndex"> L129: <em class="fa fa-trash"> L130: <la:message key="labels.clear_crawler_index_button"/> L131: ...

role="tab" L47: data-toggle="tab" L48: ><la:message key="labels.plugin_remote_install"/></a></li> L49: <li role="presentation" class="nav-item"><a href="#local" aria-controls="local" class="nav-link" role="tab" L50: data-toggle="tab"><la:message L51: key="labels.plugin_local_install"...

iterator is infinite and may cause problems if the iterator L401: * eagerly fetches data for each source when iterated (rather than producing sources that only L402: * load data through their streams). Prefer using the {@link #concat(Iterable)} overload if L403: * possible. L404: * L405: * @param sources the sources to concatenate L406: * @return a {@code ByteSource} containing the concatenated data L407: * @throws NullPointerException if any of {@code sources} is {@code null} L408:...

WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. L13: * See the License for the specific language governing permissions and L14: * limitations under the License. L15: */ L16: L17:/** L18: * An API for representing graph (node and edge) data. It is analogous to the Java Collections L19: * Framework APIs for lists, maps, sets, etc. L20: * L21: * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a> L22: * library. L23: */ L24:@CheckReturnValue...

the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending more data on this stream. When the user unpauses her video the buffer drains, the read is acknowledged, and the server proceeds to stream data. L33: L34:#### Shared reader thread L35: L36:We can't rely on application threads to read data from the socket. Application threads are transient: sometimes they're reading and writing and sometimes they're off doing application-layer...