AH
потому что там надо какие-то StreamPoint/StreamStart/StreamEnd руками эмитить
Size: a a a
2021 January 20
AH
и проставлять EventTime РУКАМИ
IC
То есть в твоей задаче, ридер - часть рх, и только аггрегейт делать через трилл
AH
не-не-не, что ж ты фраер сдал назад, давай весь пайплайн на трилле
IC
Я мельком глянул - завтра ещё посмотрю
IC
не-не-не, что ж ты фраер сдал назад, давай весь пайплайн на трилле
Мне вообще кажется, что гопак тебя наебывает
IC
Либо больше потоков либо что то ещё
AH
потоков в гопаке фиксированное кол-во
AH
это не тредпул резиновый
IC
Попробуй сколько выдаст просто цикл по ридеру?
AH
он свои потоки даже называет! они в дебагере видны
IC
Попробуй сколько выдаст просто цикл по ридеру?
Которые только читают
AH
Попробуй сколько выдаст просто цикл по ридеру?
я вот щас занят созданием репки нормальной
IC
я вот щас занят созданием репки нормальной
Давай
AH
чтобы ты тоже смог прикоснуться к прекрасному гопаку
AH
и убедиться что никто тебя не наебывает
IC
и убедиться что никто тебя не наебывает
У тебя там ещё есть executev2
IC
В говно клиенте
IC
Кстати, там просто http запрос, если сделать через http client будет значительно быстрее