mexus

#!/usr/bin/env python3

import re
import random
import string
import time
import timeit
from typing import List

regex = re.compile(r"<(?P<name>[^>]+)>")

mexus

static TIMER_COUNTER: AtomicUsize = AtomicUsize::new(0);

#[interrupt]
fn TIM2() {
    TIMER_COUNTER.fetch_add(1, Ordering::Relaxed);
}


#[cortex_m_rt::entry]
fn main() -> ! {

mexus

use std::{
    f64::consts::PI,
    io::Write,
    time::{Duration, Instant},
};

use humantime::parse_duration;
use spidev::{SpiModeFlags, Spidev, SpidevOptions};
use structopt::StructOpt;

mexus

use criterion::{criterion_group, criterion_main, Criterion};
use std::sync::Arc;

fn criterion_benchmark(c: &mut Criterion) {
    c.bench_function("arc", |b| {
        let arc = Arc::new(String::from("Some string"));
        b.iter(|| {
            let clone = Arc::clone(&arc);
            clone
        })

mexus

// In `Cargo.toml`:
// [dev-dependencies]
// criterion = "0.3.3"
// 
// [[bench]]
// name = "concat"
// harness = false

use criterion::{criterion_group, criterion_main, BatchSize, Criterion};

mexus

use std::{
    cmp::{self, Ordering},
    collections::BTreeSet,
};

#[derive(Default)]
pub struct SummaryRanges {
    ranges: BTreeSet<ClosedRange>,
}

mexus

use bytes::{Bytes, BytesMut};
use reqwest::r#async::multipart::Part;
use std::{io, path::Path};
use tokio::{
    codec::{Decoder, FramedRead},
    prelude::*,
};

struct FileCodec;
impl Decoder for FileCodec {

mexus

// [dependencies]
// serde = { version = "1", features = [ "derive" ] }
// strum = "0.15.0"
// strum_macros = "0.15.0"
// toml = "0.5.1"

use serde::{
    de::{self, Error as _},
    Deserialize, Deserializer,
};

mexus

Что такое future?

Future это тип, для которого имплементирован трейт Future

Кто вызывает poll()?

Executor. В общем случае, это может быть ивент-луп ( цикл событий,

mexus

diff --git a/src/main.rs b/src/main.rs
index b43471a..9a015a6 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -127,7 +127,7 @@ fn init_ws(r: &Client, &conn: &Connection, url: &str) {
 
                 sink.send(Message::Text(subscribe.to_string()))
                     .map_err(FHError::Send)
-                    .and_then(|_| {
+                    .and_then(|sink| {