Size: a a a

2018 August 10

D

Denis in Rust Async
МОИ ГЛАЗА
источник

D

Denis in Rust Async
почему там жёлтый бэкграунд???
источник

м

мухожук in Rust Async
Denis
почему там жёлтый бэкграунд???
даже не знаю как сообщить...
источник
2018 August 11

A

Alexander in Rust Async
читаю 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.
источник

A

Alexander in Rust Async
у pool.spawn такого нет.
источник

A

Alexander in Rust Async
хотя оно вроде и не падает: https://play.rust-lang.org/?gist=a3bdf99464fe7c86363d05560c12db5f&version=nightly&mode=debug&edition=2015  - хотя тут вроде всего два треда.
, но всё равно не очень понятно что они имеют ввиду - какой капасити? если количество тредов - то это не много.
источник

Ct

Casual tears in Rust Async
источник

A

Alexander in Rust Async
Ясно. Спасибо. Я думал за этим фьючи сами следят.
источник

A

Alik in Rust Async
Мда, столько подводных камней при работе с UDP в токио, при том недокументированных...
источник

ph

pl 🦑 hk in Rust Async
Например?
источник

A

Alik in Rust Async
pl 🦑 hk
Например?
Ok(None) в декодере, закрывает сокет. Обработка ошибок получается какая-то не такая уже))
Err(E) закрывает stream, получается что как-то криво обработывать ошибки)) Ведь stream то один.

Получается нужно как-то игнорить эти ошибки, но я пока не совсем накурился Токио и Растом.
источник

D

Denis in Rust Async
по поводу Ok(None)
источник

D

Denis in Rust Async
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"
источник

D

Denis in Rust Async
по поводу что Err закрывает stream — это не правда. некоторые комбинаторы прерывают выполнение, это да, например for_each
источник

D

Denis in Rust Async
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
источник

A

Alik in Rust Async
Denis
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"
Но finished значит что сокет закрылся, не так?)
Я говорю про это https://github.com/tokio-rs/tokio/issues/173
источник

A

Alik in Rust Async
Denis
по поводу что Err закрывает stream — это не правда. некоторые комбинаторы прерывают выполнение, это да, например for_each
Спасибо, покапаю поглубже
источник

D

Denis in Rust Async
аа, то есть они доки в удп не обновили
источник

D

Denis in Rust Async
ну дык сделай им PR :)
источник

A

Alik in Rust Async
Denis
ну дык сделай им PR :)
Я сделал свой вклад, я поставил лайк в issue : DD
источник