}

  @Override
  public void flush() throws IOException {
    checkNotClosed();
    if (target instanceof Flushable) {
      ((Flushable) target).flush();
    }
  }

  @Override
  public void close() throws IOException {
    this.closed = true;
    if (target instanceof Closeable) {
      ((Closeable) target).close();
    }
  }

  @Override

        assertNull(ex.getMessage(), "Default message should be null");
        assertNull(ex.getCause(), "Default cause should be null");
        assertTrue(ex instanceof CIFSException, "Should be a CIFSException");
        assertTrue(ex instanceof IOException, "Should be an IOException");
    }

    @Test
    @DisplayName("Should create SpnegoException with message")
    void testWithMessage() {
        // Given

        assertTrue(is instanceof InputStream);
        CloseableUtil.closeQuietly(responseData);
    }

    private void assertMatchFalse(ResponseData responseData) {
        sitemapsRule.addRule("url", Pattern.compile(".*sitemap.*"));
        assertFalse(sitemapsRule.match(responseData));
        InputStream is = responseData.getResponseBody();
        if (is instanceof TemporaryFileInputStream) {

    * This can solve nuanced errors when using middlewares. Before Starlette `0.24.0`, a new instance of each middleware class would be created when a new middleware was added. That normally was not a problem, unless the middleware class expected to be created only once, with only one instance, that happened in some cases. This upgrade would solve those cases (thanks [@adriangb](https://github.com/adriangb)! Starlette PR [#2017](https://git...

        } catch (final Exception e) {
            logger.warn("Failed to initialize Suggester.", e);
        }
    }

    /**
     * Gets the suggester instance.
     *
     * @return The suggester instance.
     */
    public Suggester suggester() {
        return suggester;
    }

    /**
     * Stores search logs in the suggest index.
     */

import (
	"gorm.io/gorm"
)

func BeginTransaction(db *gorm.DB) {
	if !db.Config.SkipDefaultTransaction && db.Error == nil {
		if tx := db.Begin(); tx.Error == nil {
			db.Statement.ConnPool = tx.Statement.ConnPool
			db.InstanceSet("gorm:started_transaction", true)
		} else if tx.Error == gorm.ErrInvalidTransaction {
			tx.Error = nil
		} else {
			db.Error = tx.Error
		}
	}
}

func CommitOrRollbackTransaction(db *gorm.DB) {

  abstract Iterator<Table.Cell<R, C, V>> cellIterator();

  @WeakOuter
  private final class CellSet extends AbstractSet<Cell<R, C, V>> {
    @Override
    public boolean contains(@Nullable Object o) {
      if (o instanceof Cell) {
        Cell<?, ?, ?> cell = (Cell<?, ?, ?>) o;
        Map<C, V> row = safeGet(rowMap(), cell.getRowKey());
        return row != null
            && Collections2.safeContains(

 * Mapping dictionaries define field mappings and transformations during the indexing process.
 *
 */
public class EditForm extends CreateForm {

    /**
     * Creates a new EditForm instance.
     */
    public EditForm() {
        super();
    }

    /**
     * The unique identifier of the mapping dictionary entry being edited.

 * Synonyms are used to expand search queries by including terms with similar meanings.
 *
 */
public class EditForm extends CreateForm {

    /**
     * Creates a new EditForm instance.
     */
    public EditForm() {
        super();
    }

    /**
     * The unique identifier of the synonym dictionary entry being edited.

     *
     * @param <T> the type to unwrap to
     * @param type the class of the type to unwrap to
     * @return session instance with the given type
     */
    <T extends SmbSession> T unwrap(Class<T> type);

    /**
     * Returns the CIFS context that this session is attached to.
     *
     * @return the context this session is attached to