wick-stdlib 0.2.0

The default standard library for the Wick project.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use futures::StreamExt;
use wick_packet::{fan_out, Observer, Packet, PacketStream};

use crate::request_response;

request_response!(job, minijob => {
  inputs: {
    input => String,
  },
  output: "output",
});

pub(crate) fn minijob(input: String) -> Result<String, wick_packet::Error> {
  println!("Logger: {}", input);
  Ok(input)
}