Skip to content

Instantly share code, notes, and snippets.

elandau

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.channel.Connection;
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
elandau / StateMachine
Created Oct 30, 2014
Rx based state machine
View StateMachine
package com.netflix.experiments.rx;
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import rx.Observable;
import rx.Observable.OnSubscribe;
@elandau
elandau / gist:6982077
Created Oct 14, 2013
JavaRX based concurrent thread model for polling data from a synchronous source
View gist:6982077
package com.netflix.schlep.rx;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import rx.Observer;
You can’t perform that action at this time.