if (len > 0 && src[srcIndex + len - 1] == '\0') {
                    len--;
                }
                str = new String(src, srcIndex, len, SmbConstants.OEM_ENCODING);
            }
        } catch (final UnsupportedEncodingException uee) {
            if (LogStream.level > 1) {
                uee.printStackTrace(log);
            }
        }
        return str;
    }

    @Override

When a WebSocket connection is closed, the `await websocket.receive_text()` will raise a `WebSocketDisconnect` exception, which you can then catch and handle like in this example.

{* ../../docs_src/websockets/tutorial003_py39.py hl[79:81] *}

To try it out:

* Open the app with several browser tabs.
* Write messages from them.

    void testGetDefaultPort() {
        // Arrange
        Handler handler = newHandler();
        // Act & Assert
        assertEquals(SmbConstants.DEFAULT_PORT, handler.getDefaultPort(), "Default port should match SmbConstants");
    }

    @Test
    @DisplayName("openConnection returns SmbFile using provided CIFSContext")
    void testOpenConnection_UsesProvidedContext() throws MalformedURLException, IOException {

e6*Math.random())}while(document.getElementById(t));return t},getSelectorFromElement:function(t){var e=t.getAttribute("data-target");if(!e||"#"===e){var n=t.getAttribute("href");e=n&&"#"!==n?n.trim():""}try{return document.querySelector(e)?e:null}catch(t){return null}},getTransitionDurationFromElement:function(t){if(!t)return 0;var e=o.default(t).css("transition-duration"),n=o.default(t).css("transition-delay"),i=parseFloat(e),a=parseFloat(n);return i||a?(e=e.split(",")[0],n=n.split(",")[0],1e3*...

        ComponentUtil.register(new DataSerializer(), "dataSerializer");
    }

    private String encodeUrl(final String url) {
        try {
            return URLEncoder.encode(url, Constants.UTF_8);
        } catch (final UnsupportedEncodingException e) {
            throw new FessSystemException("Unsupported encoding.", e);
        }
    }

    public void test_decodeUrl_ok() throws Exception {
        String url, exp;

          }
        }
      }

      val startNs = System.nanoTime()
      val response: Response
      try {
        response = chain.proceed(request)
      } catch (e: Exception) {
        val tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs)
        logger.log(
          buildString {
            append("<-- HTTP FAILED: $e.")

     */
    protected FilterChain createDefaultFilterChain() {
        return query -> {
            try {
                return createQueryParser().parse(query);
            } catch (final ParseException e) {
                throw new QueryParseException(e);
            }
        };
    }

    /**
     * Interface for query filters that can modify or transform queries.

            result.setUidNumber(DfTypeUtil.toLong(source.get("uidNumber")));
            result.setX121Address(DfTypeUtil.toString(source.get("x121Address")));
            return updateEntity(source, result);
        } catch (InstantiationException | IllegalAccessException e) {
            final String msg = "Cannot create a new instance: " + entityType.getName();
            throw new IllegalBehaviorStateException(msg, e);
        }
    }

        assertThrows(IllegalArgumentException.class, () -> getRootCause(cause));
    assertThat(expected).hasCauseThat().isSameInstanceAs(cause);
  }

  @J2ktIncompatible // Format does not match
  @GwtIncompatible // getStackTraceAsString(Throwable)
  public void testGetStackTraceAsString() {
    class StackTraceException extends Exception {
      StackTraceException(String message) {
        super(message);

              .lines()
              .first()
          if (this.launch != CommandLine) {
            println("${it.code} ${it.request.url.host} $firstLine")
          }
          Unit
        }
    } catch (e: IOException) {
      System.err.println(e)
    }
  }
}

fun main() {
  // Call this before anything else initialises the JSSE stack.
  WireSharkListenerFactory.register()