use std::sync::Arc;
mod stream_thread_spawn_iter;
mod test_sync;
use grpc::for_test::*;
use grpc::rt::*;
pub use self::stream_thread_spawn_iter::stream_thread_spawn_iter;
pub use self::test_sync::TestSync;
pub fn string_string_method(
name: &str,
streaming: GrpcStreaming,
) -> Arc<MethodDescriptor<String, String>> {
Arc::new(MethodDescriptor {
name: name.to_owned(),
streaming: streaming,
req_marshaller: Box::new(MarshallerString),
resp_marshaller: Box::new(MarshallerString),
})
}
pub const BIND_HOST: &str = "127.0.0.1";