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");

 public static class ServerPackets { @PacketDescription(id = 1) public static class MessageRequest extends AbstractReadablePacket { @Override protected void readImpl(@NotNull ConnectionOwner owner, @NotNull ByteBuffer buffer) { final String message = readString(buffer); System.out.println("Server: received \"" + message + "\""); owner.sendPacket(new MessageResponse("Response of " + message)); } } @PacketDescription(id = 2) public static class MessageResponse extends AbstractWritablePacket { @NotNull private final String message; public MessageResponse(@NotNull String message) { this.message = message; } @Override protected void writeImpl(@NotNull ByteBuffer buffer) { super.writeImpl(buffer); writeString(buffer, message); } } } public static class ClientPackets { @PacketDescription(id = 1) public static class MessageRequest extends AbstractWritablePacket { @NotNull private final String message; public MessageRequest(@NotNull String message) { this.message = message; } @Override protected void writeImpl(@NotNull ByteBuffer buffer) { super.writeImpl(buffer); writeString(buffer, message); } } @PacketDescription(id = 2) public static class MessageResponse extends AbstractReadablePacket { @Override protected void readImpl(@NotNull ConnectionOwner owner, @NotNull ByteBuffer buffer) { final String message = readString(buffer); System.out.println("client: received \"" + message + "\""); } } } var address = new InetSocketAddress(2222); serverNetwork = NetworkFactory.newDefaultAsyncServerNetwork( ReadablePacketRegistry.of(ServerPackets.MessageRequest.class)); serverNetwork.bind(address); clientNetwork = NetworkFactory.newDefaultAsyncClientNetwork( ReadablePacketRegistry.of(ClientPackets.MessageResponse.class)); clientNetwork.connect(address); var server = clientNetwork.getCurrentServer(); server.sendPacket(new ClientPackets.MessageRequest("Test client message"));