Only 21 per cent of Canadians think the country would be better off with a system where two parties dominate the political landscape

“Apple wasn’t going to beat Microsoft. Apple didn’t have to beat Microsoft,” Jobs said about the partnership.

With the 2024 election season already on it's way, it's time to remind everybody about how broken the Electoral College is, the truth about third-party...

I'm using interprocess to do ipc. This is working. I now want to develop a communication protocol using capnp-rpc + futures (as the execution environment). Interprocess's Stream implements std::io::Read & std::io::Write, while capnp-rpc's twoparty::VatNetwork::new() expects async versions (futures_io::AsyncRead & futures_io::AsyncWrite). Is there a utility crate that bridges between the sync and async versions? AsyncRead/Write from futures-io has an implementation for Pin. Could this help? let plugin_interface_client: crate::plugin::protocol_capnp::plugin_interface::Client = capnp_rpc::new_client(PluginInterfaceImpl { name: "ACMEPLUGIN".to_string() }); for mut conn in listener.incoming().filter_map(handle_error) { let network = twoparty::VatNetwork::new( Pin::new(conn.as_read()), Pin::new(conn.as_write()), rpc_twoparty_capnp::Side::Server, Default::default(), ); let rpc_system = RpcSystem::new(Box::new(network), Some(plugin_interface_client.clone().client)); ... } gives en error that it needs a &mut version of Read/Write and I don't know how to get one... error[E0277]: the trait bound `&LocalSocketStream: DerefMut` is not satisfied --> prototype/src/plugin/server.rs:78:17 | 77 | let network = twoparty::VatNetwork::new( | ------------------------- required by a bound introduced by this call 78 | Pin::new(conn.as_read()), | ^^^^^^^^^^^^^^^^^^^^^^^^ the trait `DerefMut` is not implemented for `&LocalSocketStream`, which is required by `Pin<&LocalSocketStream>: AsyncRead` | = help: the trait `AsyncRead` is implemented for `Pin<P>` = note: `DerefMut` is implemented for `&mut LocalSocketStream`, but not for `&LocalSocketStream` = note: required for `Pin<&LocalSocketStream>` to implement `AsyncRead` note: required by a bound in `capnp_rpc::twoparty::VatNetwork::<T>::new` --> /Users/xxx/.cargo/registry/src/index.crates.io-6f17d22bba15001f/capnp-rpc-0.20.2/src/twoparty.rs:231:8 | 231 | T: AsyncRead + Unpin, | ^^^^^^^^^ required by this bound in `VatNetwork::<T>::new` ... 243 | pub fn new<U>( | --- required by a bound in this associated function

YouTube video by The Sunday Shot