diff --git a/app/src/main/java/iam/thevoid/epic/timeapp/MainActivity.kt b/app/src/main/java/iam/thevoid/epic/timeapp/MainActivity.kt
index d08be6e..6a7c41a 100644
--- a/app/src/main/java/iam/thevoid/epic/timeapp/MainActivity.kt
+++ b/app/src/main/java/iam/thevoid/epic/timeapp/MainActivity.kt
@@ -1,10 +1,20 @@
 package iam.thevoid.epic.timeapp
 
+import android.graphics.Color
 import androidx.appcompat.app.AppCompatActivity
 import android.os.Bundle
+import android.util.Log
 import android.widget.Button
 import android.widget.EditText
 import android.widget.TextView
+import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers
+import io.reactivex.rxjava3.core.*
+import io.reactivex.rxjava3.disposables.Disposable
+import io.reactivex.rxjava3.schedulers.Schedulers
+import java.time.LocalTime
+import java.time.format.DateTimeFormatter
+import java.util.concurrent.TimeUnit
+import java.time.temporal.ChronoUnit.MILLIS
 
 // Дан экран с готовой разметкой
 // Реализовать при помощи RxJava
@@ -35,12 +45,19 @@ class MainActivity : AppCompatActivity() {
     private lateinit var countdownText: TextView
     private lateinit var countdownSecondsEditText: EditText
     private lateinit var countdownStartButton: Button
+    private var counter: Long = 0L
 
     // Секундомер
     private lateinit var stopwatchText: TextView
     private lateinit var stopwatchMillisText: TextView
-    private lateinit var stopwatchStartButton: EditText
-    private lateinit var stopwatchEndButton: EditText
+    private lateinit var stopwatchStartButton: Button
+    private lateinit var stopwatchEndButton: Button
+    private lateinit var stopwatchTime: LocalTime
+    private lateinit var stopwatchTimeBuf: LocalTime
+
+    private var disposableCountdown: Disposable? = null
+    private var disposableStopwatch: Disposable? = null
+    private var pause: Boolean = true
 
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
@@ -48,13 +65,146 @@ class MainActivity : AppCompatActivity() {
 
         clockText = findViewById(R.id.clockText)
 
+        Single.create<String> {
+            it.onSuccess(
+                LocalTime
+                    .now()
+                    .format(DateTimeFormatter.ofPattern("HH:mm:ss"))
+                    .toString()
+            )
+        }
+            .delay(1, TimeUnit.SECONDS)
+            .subscribeOn(Schedulers.newThread())
+            .observeOn(AndroidSchedulers.mainThread())
+            .repeat()
+            .subscribe { time ->
+                clockText.setText(time)
+            }
+
         countdownText = findViewById(R.id.countdownText)
         countdownSecondsEditText = findViewById(R.id.countdownEditText)
         countdownStartButton = findViewById(R.id.countdownStartButton)
 
+        countdownStartButton.setOnClickListener {
+            if (disposableCountdown != null) {
+                disposableCountdown?.dispose()
+                disposableCountdown = null
+                countdownText.setText("")
+            }
+            if (!countdownSecondsEditText.text.isEmpty()) {
+                counter = countdownSecondsEditText.text.toString().toLong()
+                countdownText.setText(getElapsedCountDownTime(counter))
+
+                disposableCountdown = Flowable.fromIterable(1L..counter)
+                    .concatMapCompletable {
+                        Completable
+                            .timer(1, TimeUnit.SECONDS)
+                            .observeOn(AndroidSchedulers.mainThread())
+                            .doOnComplete {
+                                val elapsedTime = counter - it;
+                                countdownText.setText(getElapsedCountDownTime(elapsedTime))
+                                if (elapsedTime == 0L) {
+                                    countdownText.setBackgroundColor(Color.RED)
+                                    Completable.timer(3, TimeUnit.SECONDS)
+                                        .observeOn(AndroidSchedulers.mainThread())
+                                        .subscribe {
+                                            countdownText.setBackgroundColor(Color.WHITE)
+                                        }
+                                }
+                            }
+                    }
+                    .subscribe()
+            }
+        }
+
         stopwatchText = findViewById(R.id.stopwatchText)
         stopwatchMillisText = findViewById(R.id.stopwatchMillisText)
         stopwatchStartButton = findViewById(R.id.stopwatchStartButton)
         stopwatchEndButton = findViewById(R.id.stopwatchEndButton)
+        clearStopwatchTime()
+
+        stopwatchStartButton.setOnClickListener {
+            Log.d(LOG_TAG, "start timer")
+            if (disposableStopwatch != null) {
+                disposableStopwatch?.dispose()
+                disposableStopwatch = null
+            }
+
+            stopwatchStartButton.setText("START")
+            stopwatchEndButton.setText("PAUSE")
+
+            if (!pause)
+                clearStopwatchTime()
+
+            stopwatchTimeBuf = LocalTime.now()
+            pause = false
+
+            disposableStopwatch = Flowable.interval(0, 1, TimeUnit.MILLISECONDS)
+                .subscribeOn(Schedulers.computation())
+                .onBackpressureDrop()
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(
+                    {
+                        val now = LocalTime.now()
+                        stopwatchTime =
+                            stopwatchTime.plus(stopwatchTimeBuf.until(now, MILLIS), MILLIS)
+                        stopwatchTimeBuf = now
+                        Log.d(
+                            LOG_TAG,
+                            (stopwatchTime.format(
+                                DateTimeFormatter.ofPattern("HH:mm:ss.SSS")
+                            ).toString())
+                        )
+                        Log.d(LOG_TAG, "time was changed")
+                        setStopwatchTimeEdit()
+                    },
+                    {
+                        Log.d(LOG_TAG, it.message.orEmpty())
+                    }
+                )
+
+        }
+
+        stopwatchEndButton.setOnClickListener {
+            disposableStopwatch?.dispose()
+            disposableStopwatch = null
+            if (pause) {
+                Log.d(LOG_TAG, "clear timer")
+                stopwatchStartButton.setText("START")
+                stopwatchEndButton.setText("PAUSE")
+                clearStopwatchTime()
+            } else {
+                Log.d(LOG_TAG, "pause timer")
+                stopwatchStartButton.setText("CONTINUE")
+                stopwatchEndButton.setText("CLEAR")
+                pause = true
+            }
+        }
+    }
+
+    private fun getElapsedCountDownTime(counter: Long): String {
+        return LocalTime.of(0, 0, 0, 0)
+            .plusSeconds(counter)
+            .format(DateTimeFormatter.ofPattern("mm:ss"))
+            .toString()
+    }
+
+    private fun clearStopwatchTime() {
+        stopwatchTime = LocalTime.of(0, 0, 0, 0)
+        setStopwatchTimeEdit()
+    }
+
+    private fun setStopwatchTimeEdit() {
+        stopwatchText.setText(
+            stopwatchTime.format(DateTimeFormatter.ofPattern("HH:mm:ss"))
+                .toString()
+        )
+        stopwatchMillisText.setText(
+            stopwatchTime.format(DateTimeFormatter.ofPattern(".SSS")).toString()
+        )
+    }
+
+    companion object {
+        private val LOG_TAG = MainActivity::class.simpleName
     }
 }
\ No newline at end of file