Skip to content

Commit

Permalink
Merge pull request #6 from ethcore/revert-5
Browse files Browse the repository at this point in the history
mostly revert #5, only import GenericIoHandler now
  • Loading branch information
arkpar authored Dec 6, 2016
2 parents 57d021e + 9fdf199 commit 1500da1
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions ipc/src/win.rs
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ use std::io;
use std::io::{Read, Write};
use std::sync::atomic::*;
use std::sync::Arc;
use jsonrpc_core::GenericIoHandler;
use jsonrpc_core::{GenericIoHandler, IoHandler};
use validator;

pub type Result<T> = std::result::Result<T, Error>;
Expand All @@ -72,12 +72,12 @@ impl std::convert::From<std::io::Error> for Error {

pub struct PipeHandler {
waiting_pipe: NamedPipe,
io_handler: Arc<GenericIoHandler>,
io_handler: Arc<IoHandler>,
}

impl PipeHandler {
/// start ipc rpc server (blocking)
pub fn start(addr: &str, io_handler: &Arc<GenericIoHandler>) -> Result<PipeHandler> {
pub fn start(addr: &str, io_handler: &Arc<IoHandler>) -> Result<PipeHandler> {
Ok(PipeHandler {
waiting_pipe: try!(
NamedPipeBuilder::new(addr)
Expand Down Expand Up @@ -175,12 +175,12 @@ pub struct Server {
is_stopping: Arc<AtomicBool>,
is_stopped: Arc<AtomicBool>,
addr: String,
io_handler: Arc<GenericIoHandler>,
io_handler: Arc<IoHandler>,
}

impl Server {
/// New server
pub fn new(socket_addr: &str, io_handler: &Arc<GenericIoHandler>) -> Result<Server> {
pub fn new(socket_addr: &str, io_handler: &Arc<IoHandler>) -> Result<Server> {
Ok(Server {
io_handler: io_handler.clone(),
is_stopping: Arc::new(AtomicBool::new(false)),
Expand Down

0 comments on commit 1500da1

Please sign in to comment.