@app.post("/items/", response_model=Item, summary="Create an item")
async def create_item(item: Item):
    """
    Create an item with all the information:

    - **name**: each item must have a name
    - **description**: a long description
    - **price**: required
    - **tax**: if the item doesn't have tax, you can omit this
    - **tags**: a set of unique tag strings for this item
    \f
    :param item: User input.
    """

    response_description="The created item",
)
async def create_item(item: Item):
    """
    Create an item with all the information:

    - **name**: each item must have a name
    - **description**: a long description
    - **price**: required
    - **tax**: if the item doesn't have tax, you can omit this
    - **tags**: a set of unique tag strings for this item
    """

import java.util.ArrayDeque
import java.util.Deque
import okio.Buffer
import org.junit.jupiter.api.AfterEach
import org.junit.jupiter.api.Test

class ServerSentEventIteratorTest {
  /** Either [Event] or [Long] items for events and retry changes, respectively.  */
  private val callbacks: Deque<Any> = ArrayDeque()

  @AfterEach
  fun after() {
    assertThat(callbacks).isEmpty()
  }

  @Test
  fun multiline() {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.entity;

import java.util.Map;

public interface SearchLogEvent {
    String getId();

    Long getVersionNo();

    Map<String, Object> toSource();

    String getEventType();

 */
package org.codelibs.fess.exception;

import jakarta.servlet.ServletException;

public class ServletRuntimeException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public ServletRuntimeException(final ServletException e) {
        super(e);
    }

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

internal fun sleepNanos(nanos: Long) {
  val ms = nanos / 1_000_000L
  val ns = nanos - (ms * 1_000_000L)
  if (ms > 0L || nanos > 0) {
    Thread.sleep(ms, ns.toInt())
  }

 */
package org.codelibs.core.exception;

/**
 * Wrapped InterruptedException.
 *
 * @author shinsuke
 *
 */
public class InterruptedRuntimeException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public InterruptedRuntimeException(final InterruptedException e) {
        super(e);
    }

    call2.execute().use { response ->
      assertThat(
        response.body.string(),
      ).isEqualTo("b")
    }

    // Calls succeed after the degraded pong timeout because the degraded pong was received.
    Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong()))
    val call3 = client.newCall(Request(server.url("/")))
    call3.execute().use { response ->

 * governing permissions and limitations under the License.
 */
package org.codelibs.curl;

public class CurlException extends RuntimeException {

    private static final long serialVersionUID = 1L;

    public CurlException(final String message, final Throwable cause) {
        super(message, cause);
    }

    public CurlException(final String message) {
        super(message);
    }

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

public class CommandExecutionException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    public CommandExecutionException(final String message) {
        super(message);
    }

    public CommandExecutionException(final String message, final Throwable e) {