node-workers 0.8.0

A pool of long-lived nodejs workers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use node_workers::WorkerPool;
use serde::Deserialize;
use std::path::Path;

#[derive(Deserialize, Debug)]
struct Property {
  pub key: String,
  #[serde(alias = "type")]
  pub propType: String,
}
#[derive(Deserialize, Debug)]
struct Interface {
  pub name: String,
  pub props: Vec<Property>,
}

fn main() {
  // Create a pool of 4 node workers
  let mut pool = WorkerPool::setup("examples/worker", 4);
  pool.with_debug(true);

  // Payloads
  let files = vec![
    Path::new("examples/user-files/user.ts")
      .canonicalize()
      .unwrap(),
    Path::new("examples/user-files/pet.ts")
      .canonicalize()
      .unwrap(),
  ];

  // execute the command "getInterfaces" on every file
  // each executed worker will return an array of interfaces (Vec<Interface>)
  let interfaces = pool
    .perform::<Vec<Interface>, _>("getInterfaces", files)
    .unwrap();
  let interfaces: Vec<Interface> = interfaces
    .into_iter()
    .map(|x| x.unwrap())
    .flatten()
    .collect();
  println!("interfaces: {:#?}", interfaces);
}