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;

lukaspili

@Layout(R.layout.view_login)
@WithComponent(LoginScreen.Component.class)
public class LoginScreen extends Path {

    @dagger.Component(dependencies = RootActivity.Component.class)
    @PerScreenScope(Component.class)
    public static interface Component extends RootActivity.Component {
        void inject(LoginView view);
    }