- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
- 93
- 94
- 95
- 96
- 97
- 98
- 99
- 100
package com.example
import kotlinx.coroutines.*
import io.ktor.network.selector.*
import io.ktor.network.sockets.*
import io.ktor.utils.io.*
import kotlinx.coroutines.channels.BroadcastChannel
import kotlinx.coroutines.channels.ClosedReceiveChannelException
import kotlinx.coroutines.channels.ConflatedBroadcastChannel
import kotlinx.coroutines.channels.ReceiveChannel
import java.io.IOException
import java.lang.StringBuilder
import java.nio.ByteBuffer
suspend fun ByteReadChannel.readString(): String {
val result = StringBuilder()
val decoder = Charsets.US_ASCII.newDecoder()
val buffer = ByteBuffer.allocate(1)
while (!isClosedForRead) {
val byte = readByte()
if (byte > 127 || byte < 0) {
continue
}
val c = decoder.decode(buffer.also {
it.put(byte)
it.rewind()
})[0]
result.append(c)
if (c == '\n') {
return result.toString().trim('\r', '\n')
}
buffer.rewind()
decoder.reset()
}
return ""
}
suspend fun ByteWriteChannel.println(text: String) {
writeStringUtf8(text)
writeStringUtf8("\r\n")
}
class Client(private val clientSocket: Socket, private val room: BroadcastChannel<String>) {
private val output = clientSocket.openWriteChannel(autoFlush = true)
private val input = clientSocket.openReadChannel()
var nick: String? = null
private set
suspend fun start() = coroutineScope {
input.discard(input.availableForRead.toLong())
output.writeStringUtf8("Welcome! And your name: ")
val nick = input.readString()
room.send("$nick is here")
output.println("Welcome $nick")
<a href="/cdn-cgi/l/email-protection" class="__cf_email__" data-cfemail="f5819d9c86b5b6999c909b81db9b9c969e">[email protected]</a> = nick
val roomSubscription = room.openSubscription()
launch {
for (message in roomSubscription) {
output.println(message)
}
}
launch {
processUserInput(nick)
}.join()
roomSubscription.cancel()
}
private suspend fun processUserInput(nick: String) {
while (!clientSocket.isClosed) {
val text = input.readString()
room.send("$nick: $text")
if (text == "bye") {
room.send("$nick left")
return
}
}
}
}
suspend fun stdoutRoomProcessor(input: ReceiveChannel<String>) {
for (message in input) {
println(message)
}
}
suspend fun server(port: Int) = coroutineScope {
val serverSocket = aSocket(ActorSelectorManager(coroutineContext)).tcp().bind(port = port)
val room = ConflatedBroadcastChannel<String>()
launch {
stdoutRoomProcessor(room.openSubscription())
}
while (coroutineContext.isActive) {
val clientSocket = serverSocket.accept()
room.send("Client connected ${clientSocket.remoteAddress}")
launch {
val client = Client(clientSocket, room)
try {
client.start()
пол кода обрезал
вот целиком
https://pastebin.com/KyizemYH
чат реально работает, хотя и тормозит
как это не нужна? как ты напишешь чат на 20 человек в один поток?
epoll, kqueue, CompletionPorts, you name it
И билиотека Ktor видимо тоже
Я спросил на "Говнокоде" что такое "ротоняк", мне ответили "погугли":
https://govnokod.ru/27445#comment631983
Я погуглил, нашел релевантной только эту ссылку. Что такое "ротоняк"?
https://youtu.be/z8-VvpONFGE
так ржал: типа андроиды, вся херня, но мало того, что роботиня-роботесса моет посуду руками, так она ещё РУКАМИ включает робот-пылесос.
я понимаю, что эта игра не про дроидов, а про угнетение, на самом деле, но сцук так обосраться
gay of the year edition!
Конечно лучше разабратся в програмировании самому, но если чтото не получантся посмотрите информацию в ШПАРГАЛКЕ
Этапы сборки:
Прожектор
Сигнальная колонна
Сенсорный выключатель
Миксер
Одометр
Спидометр
Марсоход
Чистюля
Следопыт
Нехочуха
Прилипала
Робо-сумо
- Не могу оставить тебя на такой длительный период без секса, поэтому всекс-шопе купил тебе робота.
Жена:
- Да как ты мог подумать!…да я никогда ни с кем тебе не изменю! Даже с роботом!
Муж:
- Ну, как знаешь… Если вдруг передумаешь просто крикни «ЛЁЛИК, КО МНЕ!» и он всё сделает.
Муж уезжает. Проходит две недели, жене на глаза всё время попадается ЛЁЛИК.
Жена думает:
- Жалко, конечно, денег потраченных на ЛЁЛИКА…может попробовать… чего даром стоит?
Жена решается:
- …ЛЁЛИК, КО МНЕ!!!!
ЛЁЛИК включается. 8 часов безумного, беспрерывного секса, её покидают силы, но одна проблема…жена не знает как его выключить. Изнеможенная подползает к окну,выглядывает и видит во дворе дворника Михалыча, который подметает двор.
Жена:
-Михалыч! Есть дело на бутылку! Крикни «ЛЁЛИК, КО МНЕ!!!»
Михалыч, не долго думая:
- ЛЁЛИК, КО МНЕ!!!!…
Прошло полтора месяца, муж возвращается из командировки, во дворе кучи мусора,в доме выбиты стёкла, людей на улице не видно. Из-за угла появляется Михалыч с винтовкой вместо метлы, небритый, с красными глазами…
Муж:
- Михалыч, а что произошло? Где ВСЕ????…
Михалыч:
- Тихо!!!!!!!! Бл...ь… Я не знаю, ГДЕ ВСЕ!!!!… НО… ЛЁЛИК ГДЕ-ТО РЯДОМ!
Вместо
"Михалыч! Есть дело на бутылку!"
следует читать
"Михалыч! Есть дело! На бутылку!"
Ротоняк это някнутое сокращение от ротоеб, что в данном контексте значит примерно "васян"
Перепиши на няшную.
Рядовой, прекратить веселье! Обработать пользовательский ввод! Позывной: стринги.
https://www.chiark.greenend.org.uk/~sgtatham/coroutines.html
Комплектация:
Платформа Iskra JS
Плата расширения Troyka Shield
Плата управления моторами Motor Shield
Литий-ионный аккумулятор Power Bank
50 деталей #структора, включая колёса и шаровые опоры робота 2 микромотора с редуктором 1:100 и припаянными проводами микросервопривод FS90
2 аналоговых датчика линии
2 цифровых датчика линии
ИК-приёмник ИК-пульт управления
Ультразвуковой дальномер
Светодиод
8 трёхпроводных шлейфов
Четырёхпроводной шлейф
USB-кабель
Отвёртка
Наклейки Робоняша
Роботрасса
Буклет
- надо устроить баттл с Эллочкой-людоедкой
скоро бройлеры будут на жс программировать