pavelaizen

package com.sdk.utils

import android.util.Log
import com.sdk.managers.NetworkAPIManager
import kotlinx.coroutines.experimental.CommonPool
import kotlinx.coroutines.experimental.Job
import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.launch
import java.util.concurrent.TimeUnit

pavelaizen

package com.sdk.utils

import android.util.Log
import com.sdk.managers.NetworkAPIManager
import kotlinx.coroutines.experimental.CommonPool
import kotlinx.coroutines.experimental.Job
import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.launch
import java.util.concurrent.TimeUnit

pavelaizen

/**
 * Example using Kotlin Coroutines:
 * https://kotlinlang.org/docs/tutorials/coroutines-basic-jvm.html
 */
class SampleActivity: Activity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        launch (UI){
            delay(5, TimeUnit.SECONDS)

pavelaizen

import android.app.Activity
import android.os.Bundle
import android.widget.Toast
import kotlinx.coroutines.experimental.android.UI
import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.launch
import java.util.concurrent.TimeUnit

/**
 * Example using Kotlin Coroutines:

pavelaizen

import io.mockk.*
import org.apache.logging.log4j.ThreadContext
import org.junit.Test

class Log4jExecutorTest {
    class MyLog4jExecutor : Log4jExecutor() {
        fun runBefore(t: Thread?, r: Runnable?) = beforeExecute(t, r)
    }

    @Test

pavelaizen

dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.11</version>
			<scope>test</scope>
		</dependency>
        <dependency>
            <groupId>org.jetbrains.kotlin</groupId>
            <artifactId>kotlin-stdlib</artifactId>
            <version>${kotlin.version}</version>

pavelaizen

<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.11</version>
			<scope>test</scope>
		</dependency>
        <dependency>
            <groupId>org.jetbrains.kotlin</groupId>
            <artifactId>kotlin-stdlib</artifactId>
            <version>${kotlin.version}</version>

pavelaizen

import org.apache.logging.log4j.ThreadContext
import java.util.concurrent.LinkedBlockingQueue
import java.util.concurrent.ThreadPoolExecutor
import java.util.concurrent.TimeUnit

class Log4jExecutor : ThreadPoolExecutor(1, 1,
        0L, TimeUnit.MILLISECONDS,
        LinkedBlockingQueue()) {

    override fun beforeExecute(t: Thread, r: Runnable) {

pavelaizen

import kotlinx.coroutines.experimental.Job
import kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.launch
import kotlin.coroutines.experimental.CoroutineContext

/**
 * Created by Pavel Aizendorf on 11-Apr-18.
 */
class ExpectationWatcher {
    private val jobs = mutableMapOf<String, Job>()

pavelaizen

inline fun InputStream.readChunk(data: ByteArray, block: (ByteArray, Int) -> Unit) {
    var index = 0
    do {
        read().takeIf { it != -1 }?.let { data[index++] = it.toByte() } ?: break
    } while (index < data.size)
    block(data, index)
}