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
error[E0277]: `(dyn futures_core::stream::Stream<Item = std::result::Result<bytes::bytes::Bytes, std::io::Error>> + std::marker::Send + 'static)` cannot be shared between threads safely | |
--> src/main.rs:104:22 | |
| | |
104 | app.at("/:name").get(run_query).post(save_query); | |
| ^^^ `(dyn futures_core::stream::Stream<Item = std::result::Result<bytes::bytes::Bytes, std::io::Error>> + std::marker::Send + 'static)` cannot be shared between threads safely | |
| | |
= help: the trait `std::marker::Sync` is not implemented for `(dyn futures_core::stream::Stream<Item = std::result::Result<bytes::bytes::Bytes, std::io::Error>> + std::marker::Send + 'static)` | |
= note: required because of the requirements on the impl of `std::marker::Sync` for `std::ptr::Unique<(dyn futures_core::stream::Stream<Item = std::result::Result<bytes::bytes::Bytes, std::io::Error>> + std::marker::Send + 'static)>` | |
= note: required because it appears within the type `std::boxed::Box<(dyn futures_core::stream::St |
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
use futures::future::{Future, err}; | |
fn main() { | |
let future = err("CRASH").map_err(|e| panic!("{:?}", e)); | |
tokio::run(future); | |
} |
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
error[E0277]: `*mut (dyn std::ops::Fn() + 'static)` cannot be shared between threads safely | |
--> src/lib.rs:216:24 | |
| | |
216 | AlpnConnecting(Box::pin(fut)) | |
| ^^^^^^^^^^^^^ `*mut (dyn std::ops::Fn() + 'static)` cannot be shared between threads safely | |
| | |
= help: within `core::fmt::Void`, the trait `std::marker::Sync` is not implemented for `*mut (dyn std::ops::Fn() + 'static)` | |
= note: required because it appears within the type `std::marker::PhantomData<*mut (dyn std::ops::Fn() + 'static)>` | |
= note: required because it appears within the type `core::fmt::Void` | |
= note: required because of the requirements on the impl of `std::marker::Send` for `&core::fmt::Void` |
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
#![feature(async_await, await_macro)] | |
#![recursion_limit = "128"] | |
use futures01::future::lazy; | |
use futures03::future::{FutureExt, TryFutureExt}; | |
pub struct Server { | |
name: String, | |
} |
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
const result = await photon.users.findMany({ | |
select: { | |
id: true, | |
dateOfBirth: true | |
} | |
}) |
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
index 082d750..4e45291 100644 | |
--- a/src/client.rs | |
+++ b/src/client.rs | |
@@ -91,11 +91,7 @@ pub struct Client { | |
impl Client { | |
/// Send a query to Fauna servers and parsing the response. | |
- pub fn query<'a, Q>(&self, query: Q) -> FutureResponse<Response> | |
- where | |
- Q: Into<Expr<'a>>, |
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
#[test] | |
fn test_select() { | |
let mut path = Array::from(vec!["favorites", "foods"]); | |
path.push(1); | |
let mut fun = Select::new(path, Get::instance(Ref::instance("musti"))); | |
fun.default("Chicken hearts"); | |
let query = Query::from(fun); | |
let serialized = serde_json::to_value(&query).unwrap(); |
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
use std::borrow::Cow; | |
struct Container<'a> { | |
data: Option<Cow<'a, str>>, | |
} | |
impl<'a> Container<'a> { | |
pub fn new() -> Self { | |
Self { data: None } | |
} |
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
error[E0275]: overflow evaluating the requirement `&tokio_reactor::poll_evented::PollEvented<_>: std::io::Read` | |
--> query-engine/connectors/sql-connector/src/database/mysql.rs:41:32 | |
| | |
41 | builder.ip_or_hostname(e.host.as_ref()); | |
| ^^^^^^^^^^^^^^^ | |
| | |
= help: consider adding a `#![recursion_limit="128"]` attribute to your crate | |
= note: required because of the requirements on the impl of `std::io::Read` for `&tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<_>>` | |
= note: required because of the requirements on the impl of `std::io::Read` for `&tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<_>>>` | |
= note: required because of the requirements on the impl of `std::io::Read` for `&tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<tokio_reactor::poll_evented::PollEvented<_>>>>` |
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
# This is a blocklist to block smart tv's sending meta data at home. | |
# Please help to collect domains! | |
# It could be that the TV does not receive any more updates or other services no longer work. Please report such an incident. | |
# panasonic viera | |
0077777700140002.myhomescreen.tv | |
cert-test.sandbox.google.com | |
collect-eu-fy2015.myhomescreen.tv | |
collect-eu-fy2017.myhomescreen.tv | |
collect-us-fy2016.myhomescreen.tv |