mirror of
https://gitlab.com/xmpp-rs/xmpp-rs.git
synced 2024-07-12 22:21:53 +00:00
tokio-xmpp: add build script to work around build fail on rustc 1.48
This commit is contained in:
parent
439a09122a
commit
52a2d962ee
3 changed files with 18 additions and 4 deletions
|
@ -26,5 +26,8 @@ trust-dns-proto = "0.19"
|
|||
xml5ever = "0.16"
|
||||
xmpp-parsers = "0.17"
|
||||
|
||||
[build-dependencies]
|
||||
rustc_version = "0.3"
|
||||
|
||||
[features]
|
||||
serde = ["xmpp-parsers/serde"]
|
||||
|
|
11
tokio-xmpp/build.rs
Normal file
11
tokio-xmpp/build.rs
Normal file
|
@ -0,0 +1,11 @@
|
|||
use rustc_version::version;
|
||||
|
||||
fn main() {
|
||||
let version = version().unwrap();
|
||||
|
||||
for major in 1..=version.major {
|
||||
for minor in 0..=version.minor {
|
||||
println!("cargo:rustc-cfg=rustc_least_{}_{}", major, minor);
|
||||
}
|
||||
}
|
||||
}
|
|
@ -88,19 +88,19 @@ impl<S: AsyncRead + AsyncWrite + Unpin> Sink<Packet> for XMPPStream<S> {
|
|||
Poll::Ready(Ok(()))
|
||||
}
|
||||
|
||||
fn start_send(mut self: Pin<&mut Self>, item: Packet) -> Result<(), Self::Error> {
|
||||
fn start_send(#[cfg_attr(rustc_least_1_48, allow(unused_mut))] mut self: Pin<&mut Self>, item: Packet) -> Result<(), Self::Error> {
|
||||
Pin::new(&mut self.stream.lock().unwrap().deref_mut())
|
||||
.start_send(item)
|
||||
.map_err(|e| e.into())
|
||||
}
|
||||
|
||||
fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>> {
|
||||
fn poll_flush(#[cfg_attr(rustc_least_1_48, allow(unused_mut))] mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>> {
|
||||
Pin::new(&mut self.stream.lock().unwrap().deref_mut())
|
||||
.poll_flush(cx)
|
||||
.map_err(|e| e.into())
|
||||
}
|
||||
|
||||
fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>> {
|
||||
fn poll_close(#[cfg_attr(rustc_least_1_48, allow(unused_mut))] mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Result<(), Self::Error>> {
|
||||
Pin::new(&mut self.stream.lock().unwrap().deref_mut())
|
||||
.poll_close(cx)
|
||||
.map_err(|e| e.into())
|
||||
|
@ -111,7 +111,7 @@ impl<S: AsyncRead + AsyncWrite + Unpin> Sink<Packet> for XMPPStream<S> {
|
|||
impl<S: AsyncRead + AsyncWrite + Unpin> Stream for XMPPStream<S> {
|
||||
type Item = Result<Packet, crate::Error>;
|
||||
|
||||
fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
|
||||
fn poll_next(#[cfg_attr(rustc_least_1_48, allow(unused_mut))] mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
|
||||
Pin::new(&mut self.stream.lock().unwrap().deref_mut())
|
||||
.poll_next(cx)
|
||||
.map(|result| result.map(|result| result.map_err(|e| e.into())))
|
||||
|
|
Loading…
Reference in a new issue