var container = new FakeSMTPTestContainer()
        .withSmtpPassword("pwd")
        .withSmtpUser("test_user");
    
    container.start();
    container.waitForReadyState();
    
    // sending emails to this server
    
    // checking API
    var count = container.getEmailCountFrom("from@test.com")
    // clearing API
    container.deleteEmails();

    var scanner = ClassPathScannerFactory.newDefaultScanner();
    scanner.setUseSystemClasspath(true);
    scanner.scan();

    var implementations = scanner.findImplements(Collection.class);
    var inherited = scanner.findInherited(AbstractArray.class);

    var javaSource = getClass().getResource("/java/source/TestCompileJavaSource.java");
    
    var compiler = CompilerFactory.newDefaultCompiler();
    var compiled = compiler.compile(javaSource.toURI());
    
    var instance = ClassUtils.newInstance(compiled[0]);
    var method = instance.getClass().getMethod("makeString");
    var result = method.invoke(instance);        

    var vars = VarTable.newInstance();
    vars.set("string", "Hello");
    vars.set("intArray", toIntegerArray(1, 2, 3, 5));
    vars.set("floatStringArray", "1.5,4.2,5.5");
    vars.set("stringEnum", "FLOAT");
    vars.set("enum", ReferenceType.BYTE);

    var string = vars.getString("string");
    var array = vars.getIntegerArray("intArray", "");
    var floatStringArray = vars.getFloatArray("floatStringArray", ",");
    var stringEnum = vars.getEnum("stringEnum", ReferenceType.class);
    var anEnum = vars.getEnum("enum", ReferenceType.class);
    var unsafeGet = vars.get("enum");

    var array = ArrayFactory.asArray(2, 5, 1, 7, 6, 8, 4);
    array.sort(Integer::compareTo);

    // performance operations
    var unsafe = array.asUnsafe();
    // prepare the wrapped array to have the size
    unsafe.prepareForSize(10);
    unsafe.unsafeAdd(3);
    unsafe.unsafeAdd(9);

    var first = array.first();
    var last = array.last();

    // remove the element with saving ordering
    array.slowRemove(1);
    // remove the element without saving ordering
    array.fastRemove(1);

    // search API
    Integer searched = array.search(integer -> integer == 2);
    searched = array.search(2, (el, arg) -> el == arg);

    // foreach API
    array.forEach(5, (el, arg) -> System.out.println(el + arg));
    array.forEach(5, 7, (el, firstArg, secondArg) -> System.out.println(el + firstArg + secondArg));
    
    // Stream Collector
    Array<Integer> result = IntStream.range(0, 1000)
        .mapToObj(value -> value)
        .collect(ArrayCollectors.toArray(Integer.class));

    var array = ConcurrentArray.<Integer>of(Integer.class);
    var writeStamp = array.writeLock();
    try {
        array.addAll(ArrayFactory.toArray(9, 8, 7, 6, 5, 4, 3));
        array.sort(Integer::compareTo);
    } finally {
        array.writeUnlock(writeStamp);
    }

    var readStamp = array.readLock();
    try {
        var first = array.first();
        var last = array.last();
    } finally {
        array.readUnlock(readStamp);
    }

    var last = array.getInReadLock(Array::last);
    var result = array.getInReadLock(last, (arr, target) -> arr.search(target, Integer::equals));

    array.runInWriteLock(result + 1, Collection::add);
    
    // Stream Collector
    ConcurrentArray<Integer> result = IntStream.range(0, 1000)
        .parallel()
        .mapToObj(value -> value)
        .collect(ArrayCollectors.toConcurrentArray(Integer.class));

    // getting logger by class/name
    var logger = LoggerManager.getLogger(getClass());

    // global enable/disable debug level
    LoggerLevel.DEBUG.setEnabled(true);
    
    logger.debug("Simple message");
    logger.debug(5, (val) -> "Lazy message with 5: " + val);
    logger.debug(5, 10D, (val1, val2) -> "Lazy message with 5: " + val1 + " and 10: " + val2);
    logger.debug("", "Message with a string owner.");
    logger.debug("", 5, (val) -> "Lazy message with 5: " + val);
    logger.debug("", 5, 10D, (val1, val2) -> "Lazy message with 5: " + val1 + " and 10: " + val2);
    
    // global disable debug level
    LoggerLevel.DEBUG.setEnabled(false);
    
    // local enable debug level only for this logger instance
    logger.setEnabled(LoggerLevel.DEBUG, true);
    
    // show debug message
    logger.debug("Showed");

    var config = MailSenderConfig.builder()
        .from("from@test.com")
        .host("smtp.test.com")
        .port(smtpPort)
        .password(smtpPassword)
        .username(smtpUser)
        .useAuth(true)
        .enableTtls(true)
        .sslHost("smtp.test.com")
        .build();
    
    var javaxConfig = JavaxMailSender.JavaxMailSenderConfig.builder()
        .executorKeepAlive(120)
        .executorMaxThreads(20)
        .executorMinThreads(1)
        .build();
    
    var sender = new JavaxMailSender(config, javaxConfig);
    sender.send("to@test.com", "Test Subject", "Content");
    sender.sendAsync("to@test.com", "Test Subject", "Content")
        .thenAccept(aVoid -> System.out.println("done!"));

    var serverNetwork = NetworkFactory.newStringDataServerNetwork();
    var serverAddress = serverNetwork.start();

    serverNetwork.accepted()
        .flatMap(Connection::receivedEvents)
        .subscribe(event -> {
            var message = event.packet.getData();
            System.out.println("Received from client: " + message);
            event.connection.send(new StringWritablePacket("Echo: " + message));
        });

    var clientNetwork = newStringDataClientNetwork();
    clientNetwork.connected(serverAddress)
        .doOnNext(connection -> IntStream.range(10, 100)
            .forEach(length -> connection.send(new StringWritablePacket(StringUtils.generate(length)))))
        .flatMapMany(Connection::receivedEvents)
        .subscribe(event -> System.out.println("Received from server: " + event.packet.getData()));