* [receiveRequest] in the sequence they are run.
 */
class MockSocketHandler : SocketHandler {
  private val actions = LinkedBlockingQueue<Action>()
  private val results = LinkedBlockingQueue<FutureTask<Void>>()

  fun receiveRequest(expected: String) =
    apply {
      actions += { stream ->
        val actual = stream.source.readUtf8(expected.utf8Size())

                "value": {
                    "name": "Baz",
                    "price": "thirty five point four",
                },
            },
        },
    ),
):
    results = {"item_id": item_id, "item": item}

    }

    @Override
    public int hashCode() {
        int result = hashCode;
        if (result == 0) {
            result = java.util.Objects.hash(lineNumber, columnNumber, source, locations, importedFrom);
            hashCode = result;
        }
        return result;
    }

    @Override
    public String toString() {

        String result = trans2FindNext2.toString();

        assertNotNull(result);
        assertTrue(result.contains("Trans2FindNext2"));
        assertTrue(result.contains("sid=" + TEST_SID));
        assertTrue(result.contains("searchCount=50"));
        assertTrue(result.contains("informationLevel=0x"));
        assertTrue(result.contains("resumeKey=0x" + Hexdump.toHexString(TEST_RESUME_KEY, 4)));

    tax: float | None = None


app = FastAPI()


@app.put("/items/{item_id}")
async def update_item(item_id: int, item: Item, q: str | None = None):
    result = {"item_id": item_id, **item.model_dump()}
    if q:
        result.update({"q": q})

        MojoExecution result = new MojoExecution(plugin, goal, executionId);
        result.setConfiguration(XmlNode.newInstance(executionId + "-" + goal));
        result.setMojoDescriptor(mojoDescriptor);
        result.setLifecyclePhase(mojoDescriptor.getPhase());

        return result;
    }

    public static MojoDescriptor createMojoDescriptor(String phaseName) {

                }))
                .status(ApiResult.Status.OK)
                .result());
    }

    /**
     * Creates a new synonym dictionary item.
     *
     * @param dictId the dictionary ID
     * @param body the request body containing synonym item information
     * @return JSON response with result status
     */
    // POST /api/admin/dict/synonym/setting/{dictId}
    @Execute

		{"config/iam/groups/foo/config.json", "config/iam/groups/", "config.json", "foo"},
	}
	for i, test := range specs {
		result := extractPathPrefixAndSuffix(test.path, test.prefix, test.suffix)
		if result != test.expected {
			t.Errorf("unexpected result on test[%v]: expected[%s] but had [%s]", i, test.expected, result)
		}
	}

app = FastAPI()


@app.put("/items/{item_id}")
async def update_item(item_id: int, item: Item, q: Union[str, None] = None):
    result = {"item_id": item_id, **item.model_dump()}
    if q:
        result.update({"q": q})

    @Override
    public void merge(File existing, File result) throws RepositoryException {
        merge(existing != null ? existing.toPath() : null, result != null ? result.toPath() : null);
    }

    @Override
    public void merge(Path existing, Path result) throws RepositoryException {
        Metadata recessive = read(existing);

        merge(recessive);

        write(result, metadata);

        merged = true;
    }