Created
May 12, 2023 05:23
-
-
Save bheesham/49302e63e144fcd8281e8c5386673254 to your computer and use it in GitHub Desktop.
dire straits
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Compiling ire v0.0.1 (/home/bheesham/dev/ire) | |
error[E0432]: unresolved import `futures::StartSend` | |
--> src/transport/mod.rs:3:55 | |
| | |
3 | use futures::{future::lazy, Future, task::Poll, Sink, StartSend}; | |
| ^^^^^^^^^ no `StartSend` in the root | |
error[E0432]: unresolved imports `futures::AsyncSink`, `futures::StartSend` | |
--> src/transport/ntcp/mod.rs:12:5 | |
| | |
12 | AsyncSink, Future, Sink, StartSend, Stream, | |
| ^^^^^^^^^ ^^^^^^^^^ no `StartSend` in the root | |
| | | |
| no `AsyncSink` in the root | |
| help: a similar name exists in the module: `AsyncSeek` | |
error[E0432]: unresolved import `tokio::codec` | |
--> src/transport/ntcp/mod.rs:20:5 | |
| | |
20 | codec::{Decoder, Encoder, Framed}, | |
| ^^^^^ could not find `codec` in `tokio` | |
error[E0432]: unresolved import `tokio::codec` | |
--> src/transport/ntcp/handshake/mod.rs:9:5 | |
| | |
9 | codec::{Decoder, Encoder, Framed, FramedParts}, | |
| ^^^^^ could not find `codec` in `tokio` | |
error[E0432]: unresolved imports `futures::AsyncSink`, `futures::StartSend` | |
--> src/transport/ntcp2/mod.rs:37:5 | |
| | |
37 | AsyncSink, Future, Sink, StartSend, Stream, | |
| ^^^^^^^^^ ^^^^^^^^^ no `StartSend` in the root | |
| | | |
| no `AsyncSink` in the root | |
| help: a similar name exists in the module: `AsyncSeek` | |
error[E0432]: unresolved import `tokio::codec` | |
--> src/transport/ntcp2/mod.rs:52:5 | |
| | |
52 | codec::{Decoder, Encoder, Framed}, | |
| ^^^^^ could not find `codec` in `tokio` | |
error[E0432]: unresolved import `tokio::codec` | |
--> src/transport/ntcp2/handshake/mod.rs:11:5 | |
| | |
11 | codec::{Decoder, Framed}, | |
| ^^^^^ could not find `codec` in `tokio` | |
error[E0432]: unresolved imports `futures::AsyncSink`, `futures::StartSend` | |
--> src/transport/session.rs:3:30 | |
| | |
3 | use futures::{channel::mpsc, AsyncSink, task::Poll, Sink, StartSend, Stream}; | |
| ^^^^^^^^^ ^^^^^^^^^ no `StartSend` in the root | |
| | | |
| no `AsyncSink` in the root | |
| help: a similar name exists in the module: `AsyncSeek` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/client.rs:160:5 | |
| | |
160 | type Item = Option<RouterInfo>; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/client.rs:161:5 | |
| | |
161 | type Error = Error; | |
| ^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/client.rs:196:5 | |
| | |
196 | type Item = RouterInfo; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/client.rs:197:5 | |
| | |
197 | type Error = Error; | |
| ^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/client.rs:238:5 | |
| | |
238 | type Item = LeaseSet; | |
| ^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/client.rs:239:5 | |
| | |
239 | type Error = Error; | |
| ^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/client.rs:279:5 | |
| | |
279 | type Item = Option<RouterInfo>; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/client.rs:280:5 | |
| | |
280 | type Error = Error; | |
| ^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/client.rs:321:5 | |
| | |
321 | type Item = Option<LeaseSet>; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/client.rs:322:5 | |
| | |
322 | type Error = Error; | |
| ^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0433]: failed to resolve: could not find `Loop` in `future` | |
--> src/netdb/lookup.rs:110:36 | |
| | |
110 | Ok(future::Loop::Break(found)) | |
| ^^^^ could not find `Loop` in `future` | |
error[E0433]: failed to resolve: could not find `Loop` in `future` | |
--> src/netdb/lookup.rs:112:36 | |
| | |
112 | Ok(future::Loop::Continue((found, remaining))) | |
| ^^^^ could not find `Loop` in `future` | |
error[E0433]: failed to resolve: could not find `Loop` in `future` | |
--> src/netdb/lookup.rs:240:32 | |
| | |
240 | Ok(future::Loop::Continue((lookup, peer))) | |
| ^^^^ could not find `Loop` in `future` | |
error[E0433]: failed to resolve: could not find `Loop` in `future` | |
--> src/netdb/lookup.rs:244:32 | |
| | |
244 | Ok(future::Loop::Break(())) | |
| ^^^^ could not find `Loop` in `future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/mock.rs:31:5 | |
| | |
31 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/mock.rs:32:5 | |
| | |
32 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/reseed.rs:209:5 | |
| | |
209 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/reseed.rs:210:5 | |
| | |
210 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0433]: failed to resolve: use of undeclared crate or module `task` | |
--> src/netdb/mod.rs:64:27 | |
| | |
64 | active_reseed: Option<task::JoinHandle<(), ()>>, | |
| ^^^^ use of undeclared crate or module `task` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/netdb/mod.rs:101:5 | |
| | |
101 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/netdb/mod.rs:102:5 | |
| | |
102 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp/handshake/mod.rs:534:31 | |
| | |
534 | SessionCreated((sink::Send<Framed<T, InboundHandshakeCodec>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
529 ~ enum IBHandshakeState<'a, T> | |
530 | where | |
... | |
533 | SessionRequest(StreamFuture<Framed<T, InboundHandshakeCodec>>), | |
534 ~ SessionCreated((sink::Send<'a, Framed<T, InboundHandshakeCodec>>, SystemTime)), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp/handshake/mod.rs:536:31 | |
| | |
536 | SessionConfirmB(sink::Send<Framed<T, InboundHandshakeCodec>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
529 ~ enum IBHandshakeState<'a, T> | |
530 | where | |
... | |
535 | SessionConfirmA((StreamFuture<Framed<T, InboundHandshakeCodec>>, SystemTime)), | |
536 ~ SessionConfirmB(sink::Send<'a, Framed<T, InboundHandshakeCodec>>), | |
| | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp/handshake/mod.rs:590:5 | |
| | |
590 | type Item = (RouterIdentity, Framed<T, Codec>); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp/handshake/mod.rs:591:5 | |
| | |
591 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp/handshake/mod.rs:700:31 | |
| | |
700 | SessionRequest((sink::Send<Framed<T, OutboundHandshakeCodec>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
696 ~ enum OBHandshakeState<'a, T> | |
697 | where | |
698 | T: AsyncWrite, | |
699 | { | |
700 ~ SessionRequest((sink::Send<'a, Framed<T, OutboundHandshakeCodec>>, SystemTime)), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp/handshake/mod.rs:702:31 | |
| | |
702 | SessionConfirmA(sink::Send<Framed<T, OutboundHandshakeCodec>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
696 ~ enum OBHandshakeState<'a, T> | |
697 | where | |
... | |
701 | SessionCreated((StreamFuture<Framed<T, OutboundHandshakeCodec>>, SystemTime)), | |
702 ~ SessionConfirmA(sink::Send<'a, Framed<T, OutboundHandshakeCodec>>), | |
| | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp/handshake/mod.rs:773:5 | |
| | |
773 | type Item = (RouterIdentity, Framed<T, Codec>); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp/handshake/mod.rs:774:5 | |
| | |
774 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp/mod.rs:199:5 | |
| | |
199 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp/mod.rs:200:5 | |
| | |
200 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Stream` | |
--> src/transport/ntcp/mod.rs:280:5 | |
| | |
280 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Stream` | |
error[E0407]: method `poll` is not a member of trait `Stream` | |
--> src/transport/ntcp/mod.rs:282:5 | |
| | |
282 | / fn poll(&mut self) -> Poll<Option<Self::Item>, io::Error> { | |
283 | | loop { | |
284 | | match ready!(self.upstream.poll()) { | |
285 | | Some(frame) => match frame { | |
... | | |
302 | | } | |
303 | | } | |
| |_____^ not a member of trait `Stream` | |
error[E0437]: type `SinkItem` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:332:5 | |
| | |
332 | type SinkItem = Frame; | |
| ^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0437]: type `SinkError` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:333:5 | |
| | |
333 | type SinkError = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0407]: method `poll_complete` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:339:5 | |
| | |
339 | / fn poll_complete(&mut self) -> Poll<(), io::Error> { | |
340 | | self.downstream.poll_complete() | |
341 | | } | |
| |_____^ not a member of trait `Sink` | |
error[E0437]: type `SinkItem` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:483:5 | |
| | |
483 | type SinkItem = (RouterInfo, Message); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0437]: type `SinkError` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:484:5 | |
| | |
484 | type SinkError = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0407]: method `poll_complete` is not a member of trait `Sink` | |
--> src/transport/ntcp/mod.rs:520:5 | |
| | |
520 | / fn poll_complete(&mut self) -> Poll<(), Self::SinkError> { | |
521 | | // Channels always complete immediately | |
522 | | Ok(future::ready(())) | |
523 | | } | |
| |_____^ not a member of trait `Sink` | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:54:29 | |
| | |
54 | SessionRequest(ReadExact<T, Vec<u8>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
53 ~ enum IBHandshakeState<'a, T> { | |
54 ~ SessionRequest(ReadExact<'a, T, Vec<u8>>), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:55:36 | |
| | |
55 | SessionRequestPadding(ReadExact<T, Vec<u8>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
53 ~ enum IBHandshakeState<'a, T> { | |
54 | SessionRequest(ReadExact<T, Vec<u8>>), | |
55 ~ SessionRequestPadding(ReadExact<'a, T, Vec<u8>>), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:56:29 | |
| | |
56 | SessionCreated((WriteAll<T, Vec<u8>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
53 ~ enum IBHandshakeState<'a, T> { | |
54 | SessionRequest(ReadExact<T, Vec<u8>>), | |
55 | SessionRequestPadding(ReadExact<T, Vec<u8>>), | |
56 ~ SessionCreated((WriteAll<'a, T, Vec<u8>>, SystemTime)), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:57:32 | |
| | |
57 | SessionConfirmed((ReadExact<T, Vec<u8>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
53 ~ enum IBHandshakeState<'a, T> { | |
54 | SessionRequest(ReadExact<T, Vec<u8>>), | |
55 | SessionRequestPadding(ReadExact<T, Vec<u8>>), | |
56 | SessionCreated((WriteAll<T, Vec<u8>>, SystemTime)), | |
57 ~ SessionConfirmed((ReadExact<'a, T, Vec<u8>>, SystemTime)), | |
| | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp2/handshake/mod.rs:95:5 | |
| | |
95 | type Item = (RouterInfo, Framed<T, Codec>); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp2/handshake/mod.rs:96:5 | |
| | |
96 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:275:29 | |
| | |
275 | SessionRequest((WriteAll<T, Vec<u8>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
273 ~ enum OBHandshakeState<'a, T> { | |
274 | Connecting(IoFuture<T>), | |
275 ~ SessionRequest((WriteAll<'a, T, Vec<u8>>, SystemTime)), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:276:30 | |
| | |
276 | SessionCreated((ReadExact<T, Vec<u8>>, SystemTime)), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
273 ~ enum OBHandshakeState<'a, T> { | |
274 | Connecting(IoFuture<T>), | |
275 | SessionRequest((WriteAll<T, Vec<u8>>, SystemTime)), | |
276 ~ SessionCreated((ReadExact<'a, T, Vec<u8>>, SystemTime)), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:277:36 | |
| | |
277 | SessionCreatedPadding(ReadExact<T, Vec<u8>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
273 ~ enum OBHandshakeState<'a, T> { | |
274 | Connecting(IoFuture<T>), | |
275 | SessionRequest((WriteAll<T, Vec<u8>>, SystemTime)), | |
276 | SessionCreated((ReadExact<T, Vec<u8>>, SystemTime)), | |
277 ~ SessionCreatedPadding(ReadExact<'a, T, Vec<u8>>), | |
| | |
error[E0106]: missing lifetime specifier | |
--> src/transport/ntcp2/handshake/mod.rs:278:30 | |
| | |
278 | SessionConfirmed(WriteAll<T, Vec<u8>>), | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
273 ~ enum OBHandshakeState<'a, T> { | |
274 | Connecting(IoFuture<T>), | |
... | |
277 | SessionCreatedPadding(ReadExact<T, Vec<u8>>), | |
278 ~ SessionConfirmed(WriteAll<'a, T, Vec<u8>>), | |
| | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp2/handshake/mod.rs:395:5 | |
| | |
395 | type Item = (RouterIdentity, Framed<T, Codec>); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp2/handshake/mod.rs:396:5 | |
| | |
396 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/transport/ntcp2/mod.rs:332:5 | |
| | |
332 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/transport/ntcp2/mod.rs:333:5 | |
| | |
333 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Stream` | |
--> src/transport/ntcp2/mod.rs:466:5 | |
| | |
466 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Stream` | |
error[E0407]: method `poll` is not a member of trait `Stream` | |
--> src/transport/ntcp2/mod.rs:468:5 | |
| | |
468 | / fn poll(&mut self) -> Poll<Option<Self::Item>, io::Error> { | |
469 | | loop { | |
470 | | // Return any cached messages | |
471 | | if let Some(msg) = self.cached_msgs.pop_front() { | |
... | | |
490 | | } | |
491 | | } | |
| |_____^ not a member of trait `Stream` | |
error[E0437]: type `SinkItem` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:524:5 | |
| | |
524 | type SinkItem = Block; | |
| ^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0437]: type `SinkError` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:525:5 | |
| | |
525 | type SinkError = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0407]: method `poll_complete` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:553:5 | |
| | |
553 | / fn poll_complete(&mut self) -> Poll<(), io::Error> { | |
554 | | // Package any remaining blocks in a frame | |
555 | | if !self.cached_blocks.is_empty() { | |
556 | | // Create frame from blocks | |
... | | |
568 | | self.downstream.poll_complete() | |
569 | | } | |
| |_____^ not a member of trait `Sink` | |
error[E0437]: type `SinkItem` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:804:5 | |
| | |
804 | type SinkItem = (RouterInfo, Message); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0437]: type `SinkError` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:805:5 | |
| | |
805 | type SinkError = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0407]: method `poll_complete` is not a member of trait `Sink` | |
--> src/transport/ntcp2/mod.rs:845:5 | |
| | |
845 | / fn poll_complete(&mut self) -> Poll<(), Self::SinkError> { | |
846 | | // Channels always complete immediately | |
847 | | Ok(Poll::Ready(())) | |
848 | | } | |
| |_____^ not a member of trait `Sink` | |
error[E0437]: type `Error` is not a member of trait `Stream` | |
--> src/transport/session.rs:134:5 | |
| | |
134 | type Error = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Stream` | |
error[E0407]: method `poll` is not a member of trait `Stream` | |
--> src/transport/session.rs:136:5 | |
| | |
136 | / fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error> { | |
137 | | Ok(Poll::Ready(Some(SessionRefs { | |
138 | | state: self.state.clone(), | |
139 | | distributor: self.distributor.clone(), | |
140 | | }))) | |
141 | | } | |
| |_____^ not a member of trait `Stream` | |
error[E0437]: type `SinkItem` is not a member of trait `Sink` | |
--> src/transport/mod.rs:31:5 | |
| | |
31 | type SinkItem = (RouterInfo, Message); | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0437]: type `SinkError` is not a member of trait `Sink` | |
--> src/transport/mod.rs:32:5 | |
| | |
32 | type SinkError = io::Error; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^ not a member of trait `Sink` | |
error[E0407]: method `poll_complete` is not a member of trait `Sink` | |
--> src/transport/mod.rs:41:5 | |
| | |
41 | / fn poll_complete(&mut self) -> Poll<(), Self::SinkError> { | |
42 | | self.sink.poll_complete() | |
43 | | } | |
| |_____^ not a member of trait `Sink` | |
error[E0106]: missing lifetime specifier | |
--> src/tunnel/acceptor.rs:127:18 | |
| | |
127 | f: sink::Send<mpsc::Sender<(TunnelId, HopConfig)>>, | |
| ^ expected named lifetime parameter | |
| | |
help: consider introducing a named lifetime parameter | |
| | |
126 ~ struct RegisterParticipatingState<'a, TB: TunnelBuildRequest> { | |
127 ~ f: sink::Send<'a, mpsc::Sender<(TunnelId, HopConfig)>>, | |
| | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/tunnel/acceptor.rs:171:5 | |
| | |
171 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/tunnel/acceptor.rs:172:5 | |
| | |
172 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/tunnel/acceptor.rs:439:5 | |
| | |
439 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/tunnel/acceptor.rs:440:5 | |
| | |
440 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/tunnel/processor.rs:66:5 | |
| | |
66 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/tunnel/processor.rs:67:5 | |
| | |
67 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Item` is not a member of trait `Future` | |
--> src/tunnel/processor.rs:148:5 | |
| | |
148 | type Item = (); | |
| ^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0437]: type `Error` is not a member of trait `Future` | |
--> src/tunnel/processor.rs:149:5 | |
| | |
149 | type Error = (); | |
| ^^^^^^^^^^^^^^^^ not a member of trait `Future` | |
error[E0425]: cannot find function `loop_fn` in module `future` | |
--> src/netdb/lookup.rs:106:21 | |
| | |
106 | future::loop_fn((vec![], peer_lookups), |(mut found, peer_lookups)| { | |
| ^^^^^^^ not found in `future` | |
error[E0425]: cannot find function `loop_fn` in module `future` | |
--> src/netdb/lookup.rs:235:22 | |
| | |
235 | Box::new(future::loop_fn( | |
| ^^^^^^^ not found in `future` | |
error[E0603]: struct `TcpStream` is private | |
--> src/netdb/reseed.rs:7:27 | |
| | |
7 | use tokio::{io, net::tcp::TcpStream, time::Timeout}; | |
| ^^^^^^^^^ private struct | |
| | |
note: the struct `TcpStream` is defined here | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.25/src/net/tcp/mod.rs:16:16 | |
| | |
16 | pub(crate) use stream::TcpStream; | |
| ^^^^^^^^^^^^^^^^^ | |
error[E0603]: struct `TcpListener` is private | |
--> src/transport/ntcp/mod.rs:22:16 | |
| | |
22 | net::tcp::{TcpListener, TcpStream}, | |
| ^^^^^^^^^^^ private struct | |
| | |
note: the struct `TcpListener` is defined here | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.25/src/net/tcp/mod.rs:4:16 | |
| | |
4 | pub(crate) use listener::TcpListener; | |
| ^^^^^^^^^^^^^^^^^^^^^ | |
error[E0603]: struct `TcpStream` is private | |
--> src/transport/ntcp/mod.rs:22:29 | |
| | |
22 | net::tcp::{TcpListener, TcpStream}, | |
| ^^^^^^^^^ private struct | |
| | |
note: the struct `TcpStream` is defined here | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.25/src/net/tcp/mod.rs:16:16 | |
| | |
16 | pub(crate) use stream::TcpStream; | |
| ^^^^^^^^^^^^^^^^^ | |
error[E0603]: struct `TcpListener` is private | |
--> src/transport/ntcp2/mod.rs:54:16 | |
| | |
54 | net::tcp::{TcpListener, TcpStream}, | |
| ^^^^^^^^^^^ private struct | |
| | |
note: the struct `TcpListener` is defined here | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.25/src/net/tcp/mod.rs:4:16 | |
| | |
4 | pub(crate) use listener::TcpListener; | |
| ^^^^^^^^^^^^^^^^^^^^^ | |
error[E0603]: struct `TcpStream` is private | |
--> src/transport/ntcp2/mod.rs:54:29 | |
| | |
54 | net::tcp::{TcpListener, TcpStream}, | |
| ^^^^^^^^^ private struct | |
| | |
note: the struct `TcpStream` is defined here | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-0.2.25/src/net/tcp/mod.rs:16:16 | |
| | |
16 | pub(crate) use stream::TcpStream; | |
| ^^^^^^^^^^^^^^^^^ | |
error[E0220]: associated type `Item` not found for `futures::Future` | |
--> src/netdb/reseed.rs:13:35 | |
| | |
13 | type IoFuture<T> = Box<dyn Future<Item = T, Error = io::Error> + Send>; | |
| ^^^^ associated type `Item` not found | |
error[E0220]: associated type `Error` not found for `futures::Future` | |
--> src/netdb/reseed.rs:13:45 | |
| | |
13 | type IoFuture<T> = Box<dyn Future<Item = T, Error = io::Error> + Send>; | |
| ^^^^^ associated type `Error` not found | |
error[E0191]: the value of the associated type `Output` (from trait `futures::Future`) must be specified | |
--> src/netdb/reseed.rs:13:28 | |
| | |
13 | type IoFuture<T> = Box<dyn Future<Item = T, Error = io::Error> + Send>; | |
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: specify the associated type: `Future<Item = T, Error = io::Error, Output = Type>` | |
error[E0107]: this struct takes 2 generic arguments but 1 generic argument was supplied | |
--> src/transport/ntcp/handshake/mod.rs:534:27 | |
| | |
534 | SessionCreated((sink::Send<Framed<T, InboundHandshakeCodec>>, SystemTime)), | |
| ^^^^ -------------------------------- supplied 1 generic argument | |
| | | |
| expected 2 generic arguments | |
| | |
note: struct defined here, with 2 generic parameters: `Si`, `Item` | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.28/src/sink/send.rs:11:12 | |
| | |
11 | pub struct Send<'a, Si: ?Sized, Item> { | |
| ^^^^ -- ---- | |
help: add missing generic argument | |
| | |
534 | SessionCreated((sink::Send<Framed<T, InboundHandshakeCodec>, Item>, SystemTime)), | |
| ++++++ | |
error[E0107]: this struct takes 2 generic arguments but 1 generic argument was supplied | |
--> src/transport/ntcp/handshake/mod.rs:536:27 | |
| | |
536 | SessionConfirmB(sink::Send<Framed<T, InboundHandshakeCodec>>), | |
| ^^^^ -------------------------------- supplied 1 generic argument | |
| | | |
| expected 2 generic arguments | |
| | |
note: struct defined here, with 2 generic parameters: `Si`, `Item` | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.28/src/sink/send.rs:11:12 | |
| | |
11 | pub struct Send<'a, Si: ?Sized, Item> { | |
| ^^^^ -- ---- | |
help: add missing generic argument | |
| | |
536 | SessionConfirmB(sink::Send<Framed<T, InboundHandshakeCodec>, Item>), | |
| ++++++ | |
error[E0107]: this struct takes 2 generic arguments but 1 generic argument was supplied | |
--> src/transport/ntcp/handshake/mod.rs:700:27 | |
| | |
700 | SessionRequest((sink::Send<Framed<T, OutboundHandshakeCodec>>, SystemTime)), | |
| ^^^^ --------------------------------- supplied 1 generic argument | |
| | | |
| expected 2 generic arguments | |
| | |
note: struct defined here, with 2 generic parameters: `Si`, `Item` | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.28/src/sink/send.rs:11:12 | |
| | |
11 | pub struct Send<'a, Si: ?Sized, Item> { | |
| ^^^^ -- ---- | |
help: add missing generic argument | |
| | |
700 | SessionRequest((sink::Send<Framed<T, OutboundHandshakeCodec>, Item>, SystemTime)), | |
| ++++++ | |
error[E0107]: this struct takes 2 generic arguments but 1 generic argument was supplied | |
--> src/transport/ntcp/handshake/mod.rs:702:27 | |
| | |
702 | SessionConfirmA(sink::Send<Framed<T, OutboundHandshakeCodec>>), | |
| ^^^^ --------------------------------- supplied 1 generic argument | |
| | | |
| expected 2 generic arguments | |
| | |
note: struct defined here, with 2 generic parameters: `Si`, `Item` | |
--> /home/bheesham/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.28/src/sink/send.rs:11:12 | |
| | |
11 | pub struct Send<'a, Si: ?Sized, Item> { | |
| ^^^^ -- ---- | |
help: add missing generic argument | |
| | |
702 | SessionConfirmA(sink::Send<Framed<T, OutboundHandshakeCodec>, Item>), | |
| ++++++ | |
Some errors have detailed explanations: E0106, E0107, E0191, E0220, E0407, E0425, E0432, E0433, E0437... | |
For more information about an error, try `rustc --explain E0106`. | |
error: could not compile `ire` due to 97 previous errors |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment