server.source.close()
    assertThat(client.webSocket!!.send("Hello!")).isTrue()
    taskFaker.runTasks()
    client.listener.assertFailure(IOException::class.java, "source is closed")

    // A failed write prevents further use of the WebSocket instance.
    assertThat(client.webSocket!!.send("Hello!")).isFalse()
    assertThat(client.webSocket!!.pong("Ping!".encodeUtf8())).isFalse()
  }

  @Test

Before FastAPI 0.110.0, if you used a dependency with `yield`, and then you captured an exception with `except` in that dependency, and you didn't raise the exception again, the exception would be automatically raised/forwarded to any exception handlers or the internal server error handler.

        SmbResourceLocatorImpl bad = locator("smb://badhost/");
        CIFSException ex = assertThrows(CIFSException.class, bad::getAddress);
        assertTrue(ex.getMessage().contains("Failed to lookup address"));
    }

    @Test
    @DisplayName("hashCode/equals based on address or server fallback")
    void testEqualsAndHashCode() throws Exception {
        UniAddress a = mock(UniAddress.class);

            assertEquals("abc", getIdMethod.invoke(crawlingConfigHelper, "Fabc"));
            assertEquals("xyz", getIdMethod.invoke(crawlingConfigHelper, "Dxyz"));
        } catch (Exception e) {
            fail("Failed to test getId method: " + e.getMessage());
        }
    }

    public void test_getCrawlingConfig_cacheExceptionHandling() {
        // Register a service that throws exception

    assertThat(Chars.saturatedCast(Long.MIN_VALUE)).isEqualTo(LEAST);
  }

  private void assertCastFails(long value) {
    try {
      Chars.checkedCast(value);
      fail("Cast to char should have failed: " + value);
    } catch (IllegalArgumentException ex) {
      assertWithMessage(value + " not found in exception text: " + ex.getMessage())
          .that(ex.getMessage().contains(String.valueOf(value)))
          .isTrue();

            assertFalse(testBlock.isError());

            testBlock.error();
            assertTrue(testBlock.isError());
        }

        @Test
        @DisplayName("Test verify failed state")
        void testVerifyFailedState() {
            assertFalse(testBlock.isVerifyFailed());
        }

        @Test
        @DisplayName("Test raw payload handling")

				continue
			}
			if err := saveFormatErasure(storageDisks[index], format, formatOpID); err != nil {
				healingLogIf(ctx, fmt.Errorf("Drive %s failed to write updated 'format.json': %v", storageDisks[index], err))
				storageDisks[index].Close()
				tmpNewFormats[index] = nil // this disk failed to write new format
			}
		}

		s.erasureDisksMu.Lock()

		for index, format := range tmpNewFormats {
			if format == nil {

                        contexts[i] = ctx;
                    } catch (Exception e) {
                        throw new SMBProtocolDecodingException(
                                "Failed to decode negotiate context at position " + i + ": " + e.getMessage(), e);
                    }
                }
                ncpos += dataLen;
                if (i != negotiateContextCount - 1) {

	// and the Metrics API handler returns a 500 HTTP status code. This should
	// normally not happen, and usually indicates a bug.
	logger.CriticalIf(GlobalContext, errors.Wrap(err, "failed to get metrics"))

	promMetrics := metricValues.ToPromMetrics(mg.CollectorPath.metricPrefix(),
		mg.ExtraLabels)
	for _, metric := range promMetrics {
		ch <- metric
	}
}

)

//go:generate msgp -file $GOFILE -io=false -tests=false -unexported=false

//msgp:ignore ObjectOptions TransitionOptions DeleteBucketOptions

// CheckPreconditionFn returns true if precondition check failed.
type CheckPreconditionFn func(o ObjectInfo) bool

// EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any