private static final String SECRET_MASK_REPLACE = "$1******$2";

    /**
     *
     */
    private Strings() {
    }

    /**
     * Encodes a string into bytes using the specified encoding.
     *
     * @param str the string to encode
     * @param encoding the character encoding to use
     * @return encoded byte array, or empty array if str is null
     */

     * environment.
     */
    public Type1Message() {
        this(getDefaultFlags(), getDefaultDomain(), getDefaultWorkstation());
    }

    /**
     * Creates a Type-1 message with the specified parameters.
     *
     * @param flags The flags to apply to this message.
     * @param suppliedDomain The supplied authentication domain.
     * @param suppliedWorkstation The supplied workstation name.
     */

    # o repsEnvType: (NotRequired - Default inherits or 'ut')
    #  The environment type of ReplaceSchema.
    #   e.g. if ut, data files in './playsql/data/ut/...' are loaded
    #  If DBFlute environment type is specified, inherits it as default.
    #
    #; repsEnvType = ut
    # - - - - - - - - - -/

    # /- - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    # o isLoggingInsertSql: (NotRequired - Default true)

func (ps *PubSub[T, M]) Subscribers() int32 {
	return atomic.LoadInt32(&ps.numSubscribers)
}

// New inits a PubSub system with a limit of maximum
// subscribers unless zero is specified
func New[T Maskable, M Maskable](maxSubscribers int32) *PubSub[T, M] {
	return &PubSub[T, M]{maxSubscribers: maxSubscribers}

public abstract class MethodUtil {

    /**
     * Do not instantiate.
     */
    protected MethodUtil() {
    }

    /**
     * Invokes the underlying method represented by the {@link Method} object, with the specified object and parameters.
     *
     * @param <T>
     *            The return type of the method
     * @param method
     *            The method. Cannot be {@literal null}
     * @param target

 * Test class for jcifs.smb1.util.Hexdump utility functionality
 */
@DisplayName("SMB1 Hexdump Utility Tests")
class HexdumpTest extends BaseTest {

    @Test
    @DisplayName("Should convert integer to hex string with specified size")
    void testToHexStringInt() {
        // Test zero
        assertEquals("00000000", Hexdump.toHexString(0, 8));
        assertEquals("0000", Hexdump.toHexString(0, 4));

              : delegate)
          + ")";
    }
  }

  /**
   * Returns a supplier that caches the instance supplied by the delegate and removes the cached
   * value after the specified time has passed. Subsequent calls to {@code get()} return the cached
   * value if the expiration time has not passed. After the expiration time, a new value is
   * retrieved, cached, and returned. See: <a

 * </ul>
 *
 * <p>When an instance of ContentCache is created with a byte array, the content is cached in memory.
 * When an instance is created with a File object, the content is cached in the specified file.
 *
 * <p>The {@code close()} method deletes the file if the content is cached in a file.
 *
 * <p>The {@code getInputStream()} method provides an InputStream to read the cached content.

     *
     * @param fileConfigId the ID of the file configuration to retrieve authentications for
     * @return a list of file authentication configurations for the specified file configuration
     */
    public List<FileAuthentication> getFileAuthenticationList(final String fileConfigId) {
        return fileAuthenticationBhv.selectList(cb -> {

        this.sequenceNumber = 0;
        this.responseSequenceNumber = 0;
        this.heartbeatInterval = 0;
    }

    /**
     * Creates a new WitnessHeartbeat RPC message with the specified parameters.
     *
     * @param contextHandle the context handle from registration
     * @param sequenceNumber the sequence number for this heartbeat
     */