package com.turlir.abakgists.api;

import io.reactivex.functions.Consumer;

/**
 * Эффект задержки сети на {@code millis} миллисекунд
 */
class LagSideEffect implements Consumer<Object> {

    private final int mLag;

    LagSideEffect() {
        this(5500);
    }

    LagSideEffect(int millis) {
        mLag = millis;
    }

    @Override
    public void accept(Object o) {
        try {
            Thread.sleep(mLag);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

@@ -28,16 +28,55 @@
 s.api;%0A%0A
+import java.util.concurrent.TimeUnit;%0A%0A
 import i
@@ -239,19 +239,20 @@
 e final 
-int
+long
  mLag;%0A%0A
@@ -290,12 +290,36 @@
 his(
-5500
+TimeUnit.SECONDS.toMillis(6)
 );%0A 
@@ -346,11 +346,12 @@
 ect(
-int
+long
  mil

fix LagSideEffect delay variable type