Skip to content

Instantly share code, notes, and snippets.


Block or report user

Report or block elandau

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
View gist:2a651e9d15d7d3c86178
package io.reactivex.netty.examples.tcp.loadbalancer;
import io.netty.buffer.ByteBuf;
import io.netty.handler.codec.string.StringEncoder;
import io.reactivex.netty.protocol.tcp.client.TcpClient;
import io.reactivex.netty.protocol.tcp.server.TcpServer;
import io.reactivex.netty.protocol.tcp.server.TcpServerImpl;
import io.reactivex.netty.protocol.text.StringLineDecoder;
elandau / StateMachine
Created Oct 30, 2014
Rx based state machine
View StateMachine
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import rx.Observable;
import rx.Observable.OnSubscribe;
elandau / gist:6982077
Created Oct 14, 2013
JavaRX based concurrent thread model for polling data from a synchronous source
View gist:6982077
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import rx.Observer;
You can’t perform that action at this time.