How to use reset method of org.mockito.kotlin.Mockito class

Best Mockito-kotlin code snippet using org.mockito.kotlin.Mockito.reset

QueueProcessorTest.kt

Source:QueueProcessorTest.kt

...26import com.nhaarman.mockito_kotlin.eq27import com.nhaarman.mockito_kotlin.isA28import com.nhaarman.mockito_kotlin.mock29import com.nhaarman.mockito_kotlin.never30import com.nhaarman.mockito_kotlin.reset31import com.nhaarman.mockito_kotlin.verify32import com.nhaarman.mockito_kotlin.verifyZeroInteractions33import com.nhaarman.mockito_kotlin.whenever34import java.util.concurrent.CountDownLatch35import java.util.concurrent.Executor36import java.util.concurrent.Executors37import org.jetbrains.spek.api.Spek38import org.jetbrains.spek.api.dsl.context39import org.jetbrains.spek.api.dsl.describe40import org.jetbrains.spek.api.dsl.it41import org.jetbrains.spek.api.dsl.on42object QueueProcessorTest : Spek({43  describe("the queue processor") {44    val queue: Queue = mock()45    val simpleMessageHandler: MessageHandler<SimpleMessage> = mock()46    val parentMessageHandler: MessageHandler<ParentMessage> = mock()47    val ackFunction: () -> Unit = mock()48    val activator: Activator = mock()49    val publisher: EventPublisher = mock()50    val deadMessageHandler: DeadMessageCallback = mock()51    fun resetMocks() = reset(52      queue,53      simpleMessageHandler,54      parentMessageHandler,55      ackFunction,56      publisher57    )58    describe("when disabled") {59      val subject = QueueProcessor(60        queue,61        BlockingQueueExecutor(),62        emptyList(),63        listOf(activator),64        publisher,65        deadMessageHandler66      )67      afterGroup(::resetMocks)68      on("the next polling cycle") {69        subject.poll()70      }71      it("does not poll the queue") {72        verifyZeroInteractions(queue)73      }74    }75    describe("when enabled") {76      beforeEachTest {77        whenever(activator.enabled) doReturn true78      }79      and("there is no capacity in the thread pool") {80        val executor: QueueExecutor<*> = mock()81        val subject = QueueProcessor(82          queue,83          executor,84          emptyList(),85          listOf(activator),86          publisher,87          deadMessageHandler88        )89        beforeGroup {90          whenever(executor.hasCapacity()) doReturn false91        }92        afterGroup {93          resetMocks()94          reset(executor)95        }96        action("the worker runs") {97          subject.poll()98        }99        it("does not poll the queue") {100          verifyZeroInteractions(queue)101        }102        it("fires an event") {103          verify(publisher).publishEvent(isA<NoHandlerCapacity>())104        }105      }106      and("there is capacity in the thread pool") {107        val subject = QueueProcessor(108          queue,109          BlockingQueueExecutor(),110          listOf(simpleMessageHandler, parentMessageHandler),111          listOf(activator),112          publisher,113          deadMessageHandler114        )115        describe("when a message is on the queue") {116          and("it is a supported message type") {117            val message = SimpleMessage("foo")118            beforeGroup {119              whenever(simpleMessageHandler.messageType) doReturn SimpleMessage::class.java120              whenever(parentMessageHandler.messageType) doReturn ParentMessage::class.java121              whenever(queue.poll(any())) doStub { callback: QueueCallback ->122                callback.invoke(message, ackFunction)123              }124            }125            afterGroup(::resetMocks)126            on("the next polling cycle") {127              subject.poll()128            }129            it("passes the message to the correct handler") {130              verify(simpleMessageHandler).invoke(eq(message))131            }132            it("does not invoke other handlers") {133              verify(parentMessageHandler, never()).invoke(any())134            }135            it("acknowledges the message") {136              verify(ackFunction).invoke()137            }138          }139          and("it is a subclass of a supported message type") {140            val message = ChildMessage("foo")141            beforeGroup {142              whenever(simpleMessageHandler.messageType) doReturn SimpleMessage::class.java143              whenever(parentMessageHandler.messageType) doReturn ParentMessage::class.java144              whenever(queue.poll(any())) doStub { callback: QueueCallback ->145                callback.invoke(message, ackFunction)146              }147            }148            afterGroup(::resetMocks)149            on("the next polling cycle") {150              subject.poll()151            }152            it("passes the message to the correct handler") {153              verify(parentMessageHandler).invoke(eq(message))154            }155            it("does not invoke other handlers") {156              verify(simpleMessageHandler, never()).invoke(any())157            }158            it("acknowledges the message") {159              verify(ackFunction).invoke()160            }161          }162          and("it is an unsupported message type") {163            val message = UnsupportedMessage("foo")164            beforeGroup {165              whenever(simpleMessageHandler.messageType) doReturn SimpleMessage::class.java166              whenever(parentMessageHandler.messageType) doReturn ParentMessage::class.java167              whenever(queue.poll(any())) doStub { callback: QueueCallback ->168                callback.invoke(message, ackFunction)169              }170            }171            afterGroup(::resetMocks)172            on("the next polling cycle") {173              subject.poll()174            }175            it("does not invoke any handlers") {176              verify(simpleMessageHandler, never()).invoke(any())177              verify(parentMessageHandler, never()).invoke(any())178            }179            it("does not acknowledge the message") {180              verify(ackFunction, never()).invoke()181            }182            it("sends the message to the DLQ") {183              verify(deadMessageHandler).invoke(queue, message)184            }185            it("emits an event") {186              verify(publisher).publishEvent(MessageDead)187            }188          }189          context("the handler throws an exception") {190            val message = SimpleMessage("foo")191            beforeGroup {192              whenever(simpleMessageHandler.messageType) doReturn SimpleMessage::class.java193              whenever(parentMessageHandler.messageType) doReturn ParentMessage::class.java194              whenever(queue.poll(any())) doStub { callback: QueueCallback ->195                callback.invoke(message, ackFunction)196              }197              whenever(simpleMessageHandler.invoke(any())) doThrow DummyException()198            }199            afterGroup(::resetMocks)200            on("the next polling cycle") {201              subject.poll()202            }203            it("does not acknowledge the message") {204              verify(ackFunction, never()).invoke()205            }206          }207        }208      }209    }210  }211})212@JsonTypeName("simple")213data class SimpleMessage(val payload: String) : Message()...

UserServiceImplTest.kt

Source:UserServiceImplTest.kt

1package de.submergedtree.tabletopcalendar.user2import com.nhaarman.mockito_kotlin.reset3import com.nhaarman.mockito_kotlin.times4import com.nhaarman.mockito_kotlin.verify5import com.nhaarman.mockito_kotlin.verifyNoMoreInteractions6import de.submergedtree.tabletopcalendar.gamesession.IdentifierService7import de.submergedtree.tabletopcalendar.user.impl.User8import de.submergedtree.tabletopcalendar.user.impl.UserRepository9import de.submergedtree.tabletopcalendar.user.impl.UserServiceImpl10import de.submergedtree.tabletopcalendar.usersFlux11import org.junit.jupiter.api.AfterEach12import org.junit.jupiter.api.BeforeAll13import org.junit.jupiter.api.Test14import org.junit.jupiter.api.TestInstance15import org.mockito.Mock16import org.mockito.Mockito17import org.mockito.MockitoAnnotations18import reactor.core.publisher.Mono19import reactor.test.StepVerifier20import java.util.function.Predicate21@TestInstance(TestInstance.Lifecycle.PER_CLASS)22class UserServiceImplTest {23    @Mock24    lateinit var userRepository: UserRepository25    @Mock26    lateinit var identifierService: IdentifierService27    private lateinit var userService: UserService28    @BeforeAll29    fun setUp() {30        MockitoAnnotations.initMocks(this)31        userService = UserServiceImpl(userRepository, identifierService)32    }33    @AfterEach34    fun afterEach() {35        reset(userRepository)36        reset(identifierService)37    }38    @Test39    fun getAllTest() {40        Mockito.`when`(userRepository.findAll())41                .thenReturn(usersFlux)42        val match = Predicate<User> { { u: User -> usersFlux.any { saved: User -> saved == u } }(it)43                .block()?: false }44        StepVerifier.create(userService.getAll())45                .expectNextMatches(match)46                .expectNextMatches(match)47                .verifyComplete()48    }49    @Test50    fun getUser_UserDoesNotExist() {...

ItunesViewModelTest.kt

Source:ItunesViewModelTest.kt

...3import com.example.itunesapp.model.RemoteDataModel4import com.example.itunesapp.repository.FakeRepo5import kotlinx.coroutines.*6import kotlinx.coroutines.test.TestCoroutineDispatcher7import kotlinx.coroutines.test.resetMain8import kotlinx.coroutines.test.runBlockingTest9import kotlinx.coroutines.test.setMain10import org.junit.After11import org.junit.Assert.assertEquals12import org.junit.Before13import org.junit.Rule14import org.junit.Test15import org.junit.runner.RunWith16import org.mockito.Mockito17import org.mockito.junit.MockitoJUnitRunner18import org.mockito.kotlin.mock19import org.mockito.kotlin.times20import org.mockito.kotlin.whenever21@ExperimentalCoroutinesApi22@RunWith(MockitoJUnitRunner::class)23class ItunesViewModelTest {24    @FlowPreview25    private lateinit var viewModel: ItunesViewModel26    private lateinit var  fakeRepo: FakeRepo27    private lateinit var testCoroutineDispatcher:TestCoroutineDispatcher28    @ObsoleteCoroutinesApi29    private val mainThreadSurrogate = newSingleThreadContext("UI thread")30    @ObsoleteCoroutinesApi31    @FlowPreview32    @Before33    fun onSetup(){34        fakeRepo = mock()35        testCoroutineDispatcher = TestCoroutineDispatcher()36        Dispatchers.setMain(mainThreadSurrogate)37        viewModel = ItunesViewModel(fakeRepo)38    }39    @ObsoleteCoroutinesApi40    @After41    fun cleanUp(){42        Dispatchers.resetMain()43        mainThreadSurrogate.close()44    }45    @get:Rule46    val instantTaskExecutorRule = InstantTaskExecutorRule()47//    @get:Rule48//    val coroutinesDispatcherRule = CoroutineDispatcherRule()49    @FlowPreview50    @Test51    fun `when empty value is passed list should be empty`() = testCoroutineDispatcher.runBlockingTest {52            viewModel.search("")53            assertEquals(null,viewModel.searchSongsList.value)54    }55    @FlowPreview56    @Test...

RestTjenesteSikkerhetTest.kt

Source:RestTjenesteSikkerhetTest.kt

...27    private lateinit var httpHeaderRestTemplateMock: HttpHeaderRestTemplate28    @MockBean29    private lateinit var oAuth2AuthorizedClientManagerMock: OAuth2AuthorizedClientManager30    @BeforeEach31    fun `reset Cucumber environment`() {32        Environment.reset()33    }34    @BeforeEach35    fun `stub azure security`() {36        val oaut2AuthorizedClientMock = Mockito.mock(OAuth2AuthorizedClient::class.java)37        val oauth2AccessTokenMock = Mockito.mock(OAuth2AccessToken::class.java)38        whenever(oAuth2AuthorizedClientManagerMock.authorize(any())).thenReturn(oaut2AuthorizedClientMock)39        whenever(oaut2AuthorizedClientMock.accessToken).thenReturn(oauth2AccessTokenMock)40    }41    @Test42    fun `skal generere AZURE token nÃ¥r RestTjeneste blir konfigurert`() {43        whenever(azureTokenServiceMock.cacheGeneratedToken("nais-app")).thenReturn("secured token")44        CucumberTestsModel(45            CucumberTestsApi(46                ingressesForApps = listOf("https://somewhere@nais-app"),...

RestaurantDetailViewModelTest.kt

Source:RestaurantDetailViewModelTest.kt

1package com.example.anthonyliberatore.restaurantdelivery.app.presentation2import com.example.anthonyliberatore.restaurantdelivery.app.rx.RxJavaTestHooksResetRule3import com.domain.model.Restaurant4import com.domain.usecase.GetRestaurantUseCase5import com.domain.usecase.GetRestaurantUseCase.Result6import com.example.anthonyliberatore.restaurantdelivery.app.presentation.restaurantdetail.RestaurantDetailRouter7import com.example.anthonyliberatore.restaurantdelivery.app.presentation.restaurantdetail.RestaurantDetailViewModel8import com.nhaarman.mockito_kotlin.eq9import com.nhaarman.mockito_kotlin.mock10import com.nhaarman.mockito_kotlin.verify11import io.reactivex.Observable12import org.hamcrest.CoreMatchers.equalTo13import org.hamcrest.MatcherAssert.assertThat14import org.junit.Before15import org.junit.Rule16import org.junit.Test17import org.junit.runner.RunWith18import org.mockito.BDDMockito.given19import org.mockito.Mock20import org.mockito.junit.MockitoJUnitRunner21@RunWith(MockitoJUnitRunner::class)22class RestaurantDetailViewModelTest {23  @get:Rule24  var rxJavaTestHooksResetRule = RxJavaTestHooksResetRule()25  @Mock lateinit var getRestaurantUseCase: GetRestaurantUseCase26  @Mock lateinit var restaurantDetailRouter: RestaurantDetailRouter27  private lateinit var sut: RestaurantDetailViewModel28  @Before29  fun setUp() {30    sut = RestaurantDetailViewModel(getRestaurantUseCase, restaurantDetailRouter)31  }32  @Test33  fun `bound retrieves the restaurant from the id`() {34    val id = 135    given(getRestaurantUseCase.execute(id)).willReturn(Observable.just(mock()))36    sut.bound(id)37    verify(getRestaurantUseCase).execute(eq(id))38  }39  @Test40  fun `bound shows error when retrieving the restaurant fails`() {41    val id = 142    given(getRestaurantUseCase.execute(id)).willReturn(Observable.just(Result.Failure(Throwable())))43    sut.bound(id)44    sut.showErrorGettingRestaurantDetails.observe().test().assertValue(true)45  }46  @Test47  fun `bound shows restaurant details when retrieving the restaurant`() {48    val id = 149    val restaurant = Restaurant(50            id = 1,51            name = "name",52            description = "description",53            coverImgUrl = "coverImgUrl",54            status = "status",55            deliveryFee = 056    )57    given(getRestaurantUseCase.execute(id)).willReturn(Observable.just(Result.Success(restaurant)))58    sut.bound(id)59    assertThat(sut.restaurantDescription.get(), equalTo(restaurant.description))60    assertThat(sut.restaurantName.get(), equalTo(restaurant.name))61    assertThat(sut.restaurantStatus.get(), equalTo(restaurant.status))62    assertThat(sut.restaurantImage.get(), equalTo(restaurant.coverImgUrl))63  }64}...

CoroutineTestSampleTest.kt

Source:CoroutineTestSampleTest.kt

...11import org.mockito.ArgumentMatchers.anyInt12import org.mockito.kotlin.doThrow13import org.mockito.kotlin.eq14import org.mockito.kotlin.mock15import org.mockito.kotlin.reset16import org.mockito.kotlin.times17import org.mockito.kotlin.verify18import org.mockito.kotlin.whenever19import java.lang.Exception20@ExperimentalCoroutinesApi21internal class CoroutineTestSampleTest {22    lateinit var coroutineTestSample: CoroutineTestSample23    lateinit var dummyIORepository: DummyIORepository24    private val dispatcher = TestCoroutineDispatcher()25    @BeforeEach26    fun setUp() {27        dummyIORepository = mock()28        coroutineTestSample = CoroutineTestSample(29            dummyIORepository = dummyIORepository,30            coroutineDispatcher = dispatcher31        )32    }33    @AfterEach34    fun tearDown() {35        reset(dummyIORepository)36        dispatcher.cleanupTestCoroutines()37    }38    @Nested39    inner class FetchDataTest {40        @Test41        fun `Returns the list of 1 to n in success cases`() {42            dispatcher.runBlockingTest {43                for (i in 1..10) {44                    whenever(dummyIORepository.processHeavyIO(eq(i)))45                        .thenReturn(i)46                }47                val expected = (1..10).toList()48                val actual = coroutineTestSample.fetchData(10)49                assertEquals(expected, actual)...

GetRestaurantListUseCaseTest.kt

Source:GetRestaurantListUseCaseTest.kt

1package com.domain.usecase2import com.domain.model.Restaurant3import com.domain.repository.RestaurantRepository4import com.domain.usecase.GetRestaurantListUseCase5import com.domain.usecase.GetRestaurantListUseCase.Result.Failure6import com.domain.usecase.GetRestaurantListUseCase.Result.Loading7import com.domain.usecase.GetRestaurantListUseCase.Result.Success8import com.nhaarman.mockito_kotlin.any9import com.nhaarman.mockito_kotlin.given10import com.nhaarman.mockito_kotlin.mock11import com.nhaarman.mockito_kotlin.verify12import io.reactivex.Single13import org.junit.Before14import org.junit.Rule15import org.junit.Test16import org.junit.runner.RunWith17import org.mockito.Mock18import org.mockito.junit.MockitoJUnitRunner19import com.domain.rx.RxJavaTestHooksResetRule20@RunWith(MockitoJUnitRunner::class)21class GetRestaurantListUseCaseTest {22  @get:Rule23  var rxJavaTestHooksResetRule = RxJavaTestHooksResetRule()24  @Mock lateinit var restaurantRepository: RestaurantRepository25  private lateinit var sut: GetRestaurantListUseCase26  @Before27  fun setUp() {28    sut = GetRestaurantListUseCase(restaurantRepository)29  }30  @Test31  fun `retrieves the restaurant list`() {32    given(restaurantRepository.getRestaurantList(any(), any(), any(), any())).willReturn(Single.error(Throwable()))33    sut.execute(1.1, 1.1, 0, 50).test()34    verify(restaurantRepository).getRestaurantList(any(), any(), any(), any())35  }36  @Test37  fun `shows loading to start`() {38    given(restaurantRepository.getRestaurantList(any(), any(), any(), any())).willReturn(Single.just(mock()))39    sut.execute(1.1, 1.1, 0, 50).test().assertValueAt(0) { (it == Loading) }40  }41  @Test42  fun `returns the success result when success retrieving the restaurant list`() {43    val restaurantList = arrayListOf<Restaurant>()44    given(restaurantRepository.getRestaurantList(any(), any(), any(), any())).willReturn(Single.just(restaurantList))45    sut.execute(1.1, 1.1, 0, 50).test()46        .assertValueAt(1) { (it as Success).restaurants == restaurantList }47  }48  @Test49  fun `returns the failure result when error retrieving the restaurant list`() {50    val throwable = Throwable()51    given(restaurantRepository.getRestaurantList(any(), any(), any(), any())).willReturn(Single.error(throwable))52    sut.execute(1.1, 1.1, 0, 50).test()53        .assertValueAt(1) { (it as Failure).throwable == throwable }54  }55}...

GetRestaurantUseCaseTest.kt

Source:GetRestaurantUseCaseTest.kt

1package com.domain.usecase2import com.domain.model.Restaurant3import com.domain.repository.RestaurantRepository4import com.domain.usecase.GetRestaurantUseCase5import com.domain.usecase.GetRestaurantUseCase.Result.Failure6import com.domain.usecase.GetRestaurantUseCase.Result.Loading7import com.domain.usecase.GetRestaurantUseCase.Result.Success8import com.nhaarman.mockito_kotlin.any9import com.nhaarman.mockito_kotlin.given10import com.nhaarman.mockito_kotlin.mock11import com.nhaarman.mockito_kotlin.verify12import io.reactivex.Single13import org.junit.Before14import org.junit.Rule15import org.junit.Test16import org.junit.runner.RunWith17import org.mockito.Mock18import org.mockito.junit.MockitoJUnitRunner19import com.domain.rx.RxJavaTestHooksResetRule20@RunWith(MockitoJUnitRunner::class)21class GetRestaurantUseCaseTest {22  @get:Rule23  var rxJavaTestHooksResetRule = RxJavaTestHooksResetRule()24  @Mock lateinit var restaurantRepository: RestaurantRepository25  private lateinit var sut: GetRestaurantUseCase26  @Before27  fun setUp() {28    sut = GetRestaurantUseCase(restaurantRepository)29  }30  @Test31  fun `retrieves the restaurant`() {32    given(restaurantRepository.getRestaurant(any())).willReturn(Single.error(Throwable()))33    sut.execute(1).test()34    verify(restaurantRepository).getRestaurant(any())35  }36  @Test37  fun `shows loading to start`() {38    given(restaurantRepository.getRestaurant(any())).willReturn(Single.just(mock()))39    sut.execute(1).test().assertValueAt(0) { (it == Loading) }40  }41  @Test42  fun `returns the success result when success retrieving the restaurant`() {43    val restaurant = mock<Restaurant>()44    given(restaurantRepository.getRestaurant(any())).willReturn(Single.just(restaurant))45    sut.execute(1).test()46        .assertValueAt(1) { (it as Success).restaurant == restaurant }47  }48  @Test49  fun `returns the failure result when error retrieving the restaurant`() {50    val throwable = Throwable()51    given(restaurantRepository.getRestaurant(any())).willReturn(Single.error(throwable))52    sut.execute(1).test()53        .assertValueAt(1) { (it as Failure).throwable == throwable }54  }55}...

reset

Using AI Code Generation

1reset(mock)2verify(mock).someMethod()3verify(mock, times(5)).someMethod()4verify(mock, atLeast(3)).someMethod()5verify(mock, atMost(3)).someMethod()6verify(mock, never()).someMethod()7verify(mock, timeout(100)).someMethod()8verify(mock, timeout(100).times(2)).someMethod()9verify(mock, timeout(100).atLeast(2)).someMethod()10verify(mock, timeout(100).atMost(2)).someMethod()11verify(mock, timeout(100).never()).someMethod()12verify(mock, timeout(100).only()).someMethod()13verifyNoMoreInteractions(mock)14verifyZeroInteractions(mock)15verifyNoInteractions(mock)16inOrder(mock)17inOrder(mock1, mock2)18inOrder(mock1, mock2, mock3)19inOrder(mock1, mock2, mock3, mock4)20inOrder(mock1, mock2, mock3, mock4, mock5)21inOrder(mock1, mock2, mock3, mock4, mock5, mock6)

reset

Using AI Code Generation

1    fun `test reset method of mockito kotlin`() {2        val mock = mock<SomeClass>()3        println(mock)4        reset(mock)5        println(mock)6    }7    fun `test reset method of mockito kotlin`() {8        val mock = mock<SomeClass>()9        println(mock)10        reset(mock)11        println(mock)12    }

reset

Using AI Code Generation

1val mock = mock<MockedClass>()2mock.reset()3val mock = mock<MockedClass>()4reset(mock)5resetAllMocks()6resetAllMocks()7val mock = mock<MockedClass>()8verify(mock).method1()9val mock = mock<MockedClass>()10verify(mock).method1()11val mock = mock<MockedClass>()12verify(mock, times(2)).method1()13val mock = mock<MockedClass>()14verify(mock, times(2)).method1()15val mock = mock<MockedClass>()16verify(mock, atLeastOnce()).method1()17val mock = mock<MockedClass>()18verify(mock, atLeastOnce()).method1()19val mock = mock<MockedClass>()20verify(mock, atLeast(2)).method1()

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.