Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- error[E0599]: no method named `forward` found for struct `tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>` in the current scope
- --> srv/src/server.rs:125:52
- |
- 125 | ... result = (*sender).forward(ws_tx) => if let Err(e) = result {
- | ^^^^^^^ method not found in `tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>`
- |
- ::: /home/srv_websuite/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.22/src/sync/broadcast.rs:191:1
- |
- 191 | pub struct Receiver<T> {
- | ----------------------
- | |
- | doesn't satisfy `_: futures::StreamExt`
- | doesn't satisfy `_: warp::Stream`
- |
- = note: the method `forward` exists but the following trait bounds were not satisfied:
- `tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: warp::Stream`
- which is required by `tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: futures::StreamExt`
- `&tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: warp::Stream`
- which is required by `&tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: futures::StreamExt`
- `&mut tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: warp::Stream`
- which is required by `&mut tokio::sync::broadcast::Receiver<std::result::Result<warp::ws::Message, warp::Error>>: futures::StreamExt`
- error[E0599]: no method named `poll` found for struct `std::pin::Pin<&mut _>` in the current scope
- --> srv/src/server.rs:123:29
- |
- 123 | / ... tokio::select! {
- 124 | | ... _ = close_rx.recv() => { break }
- 125 | | ... result = (*sender).forward(ws_tx) => if let Err(e) = result {
- 126 | | ... eprintln!("mpsc to websocket send error: {}", e);
- 127 | | ... }
- 128 | | ... }
- | |_______________________^ method not found in `std::pin::Pin<&mut _>`
- |
- = note: `fut` is a function, perhaps you wish to call it
- = note: this error originates in a macro (in Nightly builds, run with -Z macro-backtrace for more info)
- error[E0599]: no method named `poll` found for struct `std::pin::Pin<_>` in the current scope
- --> srv/src/server.rs:123:29
- |
- 123 | / ... tokio::select! {
- 124 | | ... _ = close_rx.recv() => { break }
- 125 | | ... result = (*sender).forward(ws_tx) => if let Err(e) = result {
- 126 | | ... eprintln!("mpsc to websocket send error: {}", e);
- 127 | | ... }
- 128 | | ... }
- | |_______________________^ method not found in `std::pin::Pin<_>`
- |
- = note: `fut` is a function, perhaps you wish to call it
- = note: this error originates in a macro (in Nightly builds, run with -Z macro-backtrace for more info)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement