* See the License for the specific language governing permissions and
 * limitations under the License.
 */

/**
 * Testing utilities. This package is a part of the open-source <a
 * href="https://github.com/google/guava">Guava</a> library.
 */
@com.google.errorprone.annotations.CheckReturnValue
@javax.annotation.ParametersAreNonnullByDefault

    @Override
    protected int doSendReceiveFragment ( byte[] buf, int off, int length, byte[] inB ) throws IOException {
        if ( this.handle.isStale() ) {
            throw new IOException("DCERPC pipe is no longer open");
        }

        int have = this.handle.sendrecv(buf, off, length, inB, getMaxRecv());

        int fraglen = Encdec.dec_uint16le(inB, 8);
        if ( fraglen > getMaxRecv() ) {

 *       that we could probably work around. Or we could manually strip the test from open-source
 *       Guava while continuing to run it internally, as we do with many other tests. This would
 *       suffice because we our Android users and tests are using the open-source version, which
 *       would no longer have the problematic test. But why bother when we can instead strip it with

 * limitations under the License.
 */
package okhttp3

import kotlin.test.assertEquals
import kotlin.test.assertFailsWith
import okhttp3.MediaType.Companion.toMediaType

open class MediaTypeGetTest : MediaTypeTest() {
  override fun parse(string: String): MediaType = string.toMediaType()

  override fun assertInvalid(
    string: String,
    exceptionMessage: String?,
  ) {
    val e =

 * limitations under the License.
 */

/**
 * Testing utilities for use in tests of {@code com.google.common.escape}.
 *
 * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a>
 * library.
 */
@CheckReturnValue
package com.google.common.escape.testing;

 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

/**
 * Utilities for reflection. This package is a part of the open-source <a
 * href="https://github.com/google/guava">Guava</a> library.
 */
@CheckReturnValue
@ParametersAreNonnullByDefault
package com.google.common.reflect;

import com.google.errorprone.annotations.CheckReturnValue;

 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

/**
 * Escapers
 * for
 * XML.
 *
 * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a>
 * library.
 */
@CheckReturnValue
@ParametersAreNonnullByDefault
package com.google.common.xml;

import com.google.errorprone.annotations.CheckReturnValue;

 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

/**
 * Escapers
 * for
 * HTML.
 *
 * <p>This package is a part of the open-source <a href="https://github.com/google/guava">Guava</a>
 * library.
 */
@CheckReturnValue
@ParametersAreNonnullByDefault
package com.google.common.html;

import com.google.errorprone.annotations.CheckReturnValue;

from typing import Union

from fastapi import BackgroundTasks, Depends, FastAPI

app = FastAPI()


def write_log(message: str):
    with open("log.txt", mode="a") as log:
        log.write(message)


def get_query(background_tasks: BackgroundTasks, q: Union[str, None] = None):
    if q:
        message = f"found query: {q}\n"
        background_tasks.add_task(write_log, message)
    return q

    response = client.post("/send-notification/******@****.***?q=some-query")
    assert response.status_code == 200, response.text
    assert response.json() == {"message": "Message sent"}
    with open("./log.txt") as f: