backtalk 0.1.0

An asynchronous, streaming web server for JSON APIs
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

extern crate backtalk;
extern crate futures;

use backtalk::*;
use std::sync::Arc;

fn main() {
  let mut s = Server::new();
  s.resource("/meow", |_req: Request| {
    Error::forbidden("not allowed! sorry.")
  });
  let adapter = Arc::new(memory::MemoryAdapter::new());
  let channel = Arc::new(memory::MemoryChannel::new());
  s.resource("/hello2", move |req: Request| {
    req
      .and_then(|req| {
        req.into_reply(JsonObject::new())
      })
  });
  s.resource("/hello", move |req: Request| {
    let adapter = adapter.clone();
    let channel1 = channel.clone();
    // let channel2 = channel.clone();
    req
      .and_then(move |req| {
        match req.method().clone() {
          Method::Action(_) => Error::forbidden("not allowed! sorry."),
          Method::Listen => channel1.handle(req),
          _ => adapter.handle(req),
        }
      })
      // .and_then(move |reply| { util::send_from_reply(reply, channel2.deref()) })
  });
  s.listen("127.0.0.1:3000");
}