Skip to content

Instantly share code, notes, and snippets.

@silvadanilo
silvadanilo / infinite-reconnect.rs
Last active May 16, 2019 09:03
Asynchronously reconnecting a client to a server in an infinite loop
extern crate futures;
extern crate tokio_core;
extern crate tokio_line;
use futures::future::{self, Future, Loop};
use futures::{Stream};
use std::{io, str};
use tokio_core::io::{Io};
use tokio_core::net::{TcpStream};
use tokio_core::reactor::{Core, Handle};
@silvadanilo
silvadanilo / sample_sink.rs
Last active February 18, 2017 15:51
sink implementation sample
extern crate futures;
extern crate tokio_core;
use futures::{Async, AsyncSink, StartSend, Poll, Sink, IntoFuture, Future, future};
use futures::sync::mpsc::{SendError};
use futures::Async::{NotReady, Ready};
use futures::sync::mpsc::UnboundedReceiver;
use futures::sync::mpsc;
use futures::task::{self, Task};
use tokio_core::reactor::{Core, Timeout};
<?php
include 'vendor/autoload.php';
use Monolog\Logger;
use Monolog\Handler\SocketHandler;
// create a log channel
$log = new Logger('name');
$socketHandler = new SocketHandler('localhost:1234', Logger::WARNING);
/* $socketHandler->setWritingTimeout(5); */
-module(fizzbuzz).
-export([evaluateV1/1]).
-export([evaluateV2/1]).
-export([evaluateV3/1]).
-export([evaluateV4/1]).
-include_lib("eunit/include/eunit.hrl").
divisorToWordMap() ->
#{
<?php
namespace KbizeCli\Http\Exception;
class ServerErrorResponseException
{
public static function fromRaw($raw)
{
$e = new self($raw->getMessage(), $raw->getCode(), $raw->getPrevious());
return $e;