private final Map<ByteString, Listener> listeners = new LinkedHashMap<>();

  public OAuthSessionFactory(SlackApi slackApi) {
    this.slackApi = slackApi;
  }

  public void start() throws Exception {
    if (mockWebServer != null) throw new IllegalStateException();

    mockWebServer = new MockWebServer();
    mockWebServer.setDispatcher(this);
    mockWebServer.start(slackApi.port);
  }

                this.socket.close();
                log.trace("Socket closed");
            } else {
                log.trace("Not yet initialized");
            }
        } catch (final Exception e) {
            log.debug("Exception in disconnect", e);
        } finally {
            this.socket = null;
            this.digest = null;
            this.tconHostName = null;

  /**
   * {@inheritDoc}
   *
   * @throws IllegalArgumentException if the given value is already bound to a different key in this
   *     bimap. The bimap will remain unmodified in this event. To avoid this exception, call {@link
   *     #forcePut} instead.
   */
  @CanIgnoreReturnValue
  @Override
  @Nullable V put(@ParametricNullness K key, @ParametricNullness V value);

  /**

        return "app.xml";
    }

    @Override
    protected boolean isUseOneTimeContainer() {
        return true;
    }

    @Override
    public void setUp() throws Exception {
        // create runner instance
        runner = new OpenSearchRunner();
        // create ES nodes
        final String clusterName = UUID.randomUUID().toString();
        runner.onBuild((number, settingsBuilder) -> {

            // Act
            smbFile.connect();

            // Assert - should not throw exception
        }

        @Test
        void testClose() {
            // Act
            smbFile.close();

            // Assert - should not throw exception
        }

        @Test
        void testGetTransportContext() {
            // Act & Assert

      call.cancelLater(500.milliseconds)
      val trailersDelay =
        measureTime {
          val exception =
            assertFailsWith<IOException> {
              response.trailers()
            }
          assertThat(exception.message).isIn(
            "Socket closed", // HTTP/1.1
            "stream was reset: CANCEL", // HTTP/2
          )
        }

public class FessCookieResourceProviderTest extends UnitFessTestCase {

    private FessCookieResourceProvider cookieResourceProvider;
    private FessConfig originalFessConfig;

    @Override
    public void setUp() throws Exception {
        super.setUp();

        originalFessConfig = ComponentUtil.getFessConfig();

        // Set up test FessConfig
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {

        try {
            executorService.execute(() -> {
                try {
                    task.expired();
                } catch (final Exception e) {
                    if (e instanceof InterruptedException) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Interrupted.", e);
                        }

@Deprecated
class ProjectClasspathTestType extends AbstractMavenProjectTestCase {
    static final String DIR = "projects/scope/";

    @Override
    @BeforeEach
    public void setUp() throws Exception {
        super.setUp();

        ArtifactResolver resolver = getContainer().lookup(ArtifactResolver.class, "classpath");
        DefaultArtifactDescriptorReader pomReader =

                System.arraycopy(auth.getUnicodeHash(transport.server.encryptionKey), 0, macSigningKey, 16, 24);
                break;
            }
        } catch (final Exception ex) {
            throw new SmbException("", ex);
        }
        if (LogStream.level >= 5) {
            log.println("LM_COMPATIBILITY=" + LM_COMPATIBILITY);