RoryKelly

/**
 * Takes a bytes source and streams it to parallel sources. I.E Streaming bytes to two server in parallel.
 */
public final class MirroredSource {

    private final Buffer buffer = new Buffer();
    private final Source source;
    private final AtomicBoolean sourceExhausted = new AtomicBoolean();
    private boolean closed = false;