Телеграмм чат группы rustlang

да: https://docs.rs/tokio/0.3.5/tokio/sync/mpsc/fn.channel.html

docs.rs

tokio::sync::mpsc::channel - Rust

API documentation for the Rust `channel` fn in crate `tokio`.

понятно, спасибо

Roma S in Rust — русскоговорящее сообществo

13:53пожаловаться #1

Roman Q

это кажется накладно - создавать нового консьюмера на каждый новый сабскрипшен

зависит от количества из размера сообщений, кмк. но с другой стороны, как @kitsu пишет — будет проще управлять (если самому бродкастить, то надо как-то для каждого внутреннего потребителя сохранять офсет сообщения, обработанного и тд)

Roman Q in Rust — русскоговорящее сообществo

13:53пожаловаться #2

Roma S

согласен. для моей задачи подойдет новый консьюмер с уникальным group_id

Mikhail Voronov in Rust — русскоговорящее сообществo

14:00пожаловаться #3

а как в интеграционных тестах инклудить модули во вложенных папках, вот допустим как при таком лайауте

- tests
---- dashboard
------ utils.rs
---- dashboard.rs

в dashboard.rs заинклудить utils.rs?

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

15:41пожаловаться #4

ΑZ

отлищно, у ArgGroup есть флажок multiple, вот так работает:

use structopt::clap::ArgGroup;
use structopt::StructOpt;

#[derive(Debug, StructOpt)]
#[structopt(
    group = ArgGroup::with_name("verbosity").multiple(false),
)]
struct Opt {
    #[structopt(long, group = "verbosity")]
    verbose: bool,
    #[structopt(long, group = "verbosity")]
    quiet: bool,
}

fn main() {
    dbg!(Opt::from_args());
}

а как насчет сделать enum LogLevel { Verbose, Quiet } и не парить себе мозг?) Заодно получишь возможность писать if loglevel >= LogLevel::Debug виместо if debug || info || warn || error { .. }

16:05пожаловаться #5

match (args.verbose, args.quiet) {
    (true, _) => LevelFilter::Debug,
    (_, true) => LevelFilter::Warn,
    _ => LevelFilter::Info,
}

у лога ж есть енум, и так читабельно выходит

16:35пожаловаться #6

ну и со своим енамом кажется придется плясать с парсингом енума

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

16:36пожаловаться #7

ΑZ

match (args.verbose, args.quiet) {
    (true, _) => LevelFilter::Debug,
    (_, true) => LevelFilter::Warn,
    _ => LevelFilter::Info,
}

у лога ж есть енум, и так читабельно выходит

не забудь args.info, args.error, args.warn

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

16:36пожаловаться #8

ΑZ

ну и со своим енамом кажется придется плясать с парсингом енума

если он бул парсит то думаешь энум не сможет?

16:37пожаловаться #9

не забудь args.info, args.error, args.warn

да мне и не нужно

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

16:37пожаловаться #10

ΑZ

да мне и не нужно

ну может потом будет нужно. В любом случае это правильно. —log info никак не сложнее

16:37пожаловаться #11

если он бул парсит то думаешь энум не сможет?

Скажи как, я не в курсе

16:38пожаловаться #12

ну может потом будет нужно. В любом случае это правильно. —log info никак не сложнее

Вот если понадобится, тогда и переделываю. Зачем решать несуществующие задачи

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

16:39пожаловаться #13

ΑZ

use clap::arg_enum;
use structopt::StructOpt;

#[structopt(long = "log",
      raw(possible_values = "&LogLevel::variants()", case_insensitive = "true"),
      raw(default_value = "Verbose"))]
pub log_level: LogLevel,

arg_enum! {
    #[derive(Debug)]
    enum LogLevel {
        Verbose,
        Info,
        Warn
    }
}

16:40пожаловаться #14

use clap::arg_enum;
use structopt::StructOpt;

#[structopt(long = "log",
      raw(possible_values = "&LogLevel::variants()", case_insensitive = "true"),
      raw(default_value = "Verbose"))]
pub log_level: LogLevel,

arg_enum! {
    #[derive(Debug)]
    enum LogLevel {
        Verbose,
        Info,
        Warn
    }
}

о неплохо, спасибо

16:49пожаловаться #15

жаль правда что структуру нужно дублировать

Αλεχ Zhukovsky in Rust — русскоговорящее сообществo

16:50пожаловаться #16

ΑZ

Что дублировать?