D
МОИ ГЛАЗА
Size: a a a
2018 August 10
D
почему там жёлтый бэкграунд???
м
почему там жёлтый бэкграунд???
даже не знаю как сообщить...
2018 August 11
A
читаю spawn у Sender: https://tokio-rs.github.io/tokio/tokio_threadpool/struct.Sender.html и очень напрягает If spawn returns Err, then the future failed to be spawned. There are two possible causes:
The thread pool is at capacity and is unable to spawn a new future. This is a temporary failure. At some point in the future, the thread pool might be able to spawn new futures.
The thread pool is at capacity and is unable to spawn a new future. This is a temporary failure. At some point in the future, the thread pool might be able to spawn new futures.
A
у pool.spawn такого нет.
A
хотя оно вроде и не падает: https://play.rust-lang.org/?gist=a3bdf99464fe7c86363d05560c12db5f&version=nightly&mode=debug&edition=2015 - хотя тут вроде всего два треда.
, но всё равно не очень понятно что они имеют ввиду - какой капасити? если количество тредов - то это не много.
, но всё равно не очень понятно что они имеют ввиду - какой капасити? если количество тредов - то это не много.
A
A
Мда, столько подводных камней при работе с UDP в токио, при том недокументированных...
ph
Например?
A
Например?
Ok(None) в декодере, закрывает сокет. Обработка ошибок получается какая-то не такая уже))
Err(E) закрывает stream, получается что как-то криво обработывать ошибки)) Ведь stream то один.
Получается нужно как-то игнорить эти ошибки, но я пока не совсем накурился Токио и Растом.
Err(E) закрывает stream, получается что как-то криво обработывать ошибки)) Ведь stream то один.
Получается нужно как-то игнорить эти ошибки, но я пока не совсем накурился Токио и Растом.
D
по поводу
Ok(None)D
https://docs.rs/futures/0.1.23/futures/stream/trait.Stream.html#tymethod.poll
> Once a stream is finished, that is Ready(None) has been returned, further calls to poll may result in a panic or other "bad behavior"
> Once a stream is finished, that is Ready(None) has been returned, further calls to poll may result in a panic or other "bad behavior"
D
по поводу что
Err закрывает stream — это не правда. некоторые комбинаторы прерывают выполнение, это да, например for_eachD
https://docs.rs/futures/0.1.23/futures/stream/trait.Stream.html#method.for_each
> Any error on the stream or in the closure will cause iteration to be halted immediately and the future will resolve to that error
> Any error on the stream or in the closure will cause iteration to be halted immediately and the future will resolve to that error
A
https://docs.rs/futures/0.1.23/futures/stream/trait.Stream.html#tymethod.poll
> Once a stream is finished, that is Ready(None) has been returned, further calls to poll may result in a panic or other "bad behavior"
> Once a stream is finished, that is Ready(None) has been returned, further calls to poll may result in a panic or other "bad behavior"
Но finished значит что сокет закрылся, не так?)
Я говорю про это https://github.com/tokio-rs/tokio/issues/173
Я говорю про это https://github.com/tokio-rs/tokio/issues/173
A
по поводу что
Err закрывает stream — это не правда. некоторые комбинаторы прерывают выполнение, это да, например for_eachСпасибо, покапаю поглубже
D
Но finished значит что сокет закрылся, не так?)
Я говорю про это https://github.com/tokio-rs/tokio/issues/173
Я говорю про это https://github.com/tokio-rs/tokio/issues/173
аа, то есть они доки в удп не обновили
D
ну дык сделай им PR :)
A
ну дык сделай им PR :)
Я сделал свой вклад, я поставил лайк в issue : DD