yuk1ty

private void doRead(SocketChannel socketChannel) throws NioHttpServerException {
    try {
      ByteBuffer buf = ByteBuffer.allocate(1024);
      socketChannel.read(buf);
      buf.flip();

      Option<Request> maybeRequest = requestHandler.apply(buf);
      buf.clear();

      Option<Either<Exception, Response>> maybeResponse =

yuk1ty

public void start() throws NioHttpServerException {
    InputStream inputStream = inputStream();

    requestHandler
        .apply(inputStream)
        .toStream()
        .map(
            v -> {
              switch (v.status()) {
                case OK:

yuk1ty

@FunctionalInterface
public interface ThrowableSupplier<T> {
  T get() throws Exception;
}

yuk1ty

extern crate hyper;
extern crate tokio_core;
extern crate futures;

use hyper::{Client, Uri};
use tokio_core::reactor::Core;
use futures::future::Future;

// 処理のブロックが起きてしまっている例
fn main() {

yuk1ty

import exception.ParseException
import token._

trait Lexer {

  protected val input: String

  protected var p: Int

  protected var current: Char

yuk1ty

pub struct Request {
    head: Parts,
}

pub struct Parts {
    pub method: String,
    pub uri: String,
    pub http_version: String,
}