// Path: android-client/client/src/main/java/edu/cmu/cs/gabriel/client/results/ErrorType.java
// public enum ErrorType {
//     SERVER_ERROR,
//     SERVER_DISCONNECTED,
//     COULD_NOT_CONNECT
// }


import android.util.Log;
import com.tinder.scarlet.Lifecycle;
import com.tinder.scarlet.ShutdownReason;
import com.tinder.scarlet.Stream.Observer;
import com.tinder.scarlet.WebSocket.Event;
import com.tinder.scarlet.lifecycle.LifecycleRegistry;
import org.jetbrains.annotations.NotNull;
import java.util.function.Consumer;
import edu.cmu.cs.gabriel.client.results.ErrorType;
package edu.cmu.cs.gabriel.client.observer;






public class EventObserver implements Observer<Event> {
    private static final String TAG = "EventObserver";

    private final LifecycleRegistry lifecycleRegistry;
// Path: android-client/client/src/main/java/edu/cmu/cs/gabriel/client/results/ErrorType.java
// public enum ErrorType {
//     SERVER_ERROR,
//     SERVER_DISCONNECTED,
//     COULD_NOT_CONNECT
// }


// Path: android-client/client/src/main/java/edu/cmu/cs/gabriel/client/observer/EventObserver.java
import android.util.Log;
import com.tinder.scarlet.Lifecycle;
import com.tinder.scarlet.ShutdownReason;
import com.tinder.scarlet.Stream.Observer;
import com.tinder.scarlet.WebSocket.Event;
import com.tinder.scarlet.lifecycle.LifecycleRegistry;
import org.jetbrains.annotations.NotNull;
import java.util.function.Consumer;
import edu.cmu.cs.gabriel.client.results.ErrorType;

package edu.cmu.cs.gabriel.client.observer;






public class EventObserver implements Observer<Event> {
    private static final String TAG = "EventObserver";

    private final LifecycleRegistry lifecycleRegistry;
    private final Consumer<ErrorType> onDisconnect;