RxJava/src/test/java/io/reactivex/NotificationTest.java at 2.x · hemanthgit/RxJava · GitHub

History

66 lines (52 loc) · 2.32 KB

Raw

/**

* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in

* compliance with the License. You may obtain a copy of the License at

* http://www.apache.org/licenses/LICENSE-2.0

* Unless required by applicable law or agreed to in writing, software distributed under the License is

* distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See

* the License for the specific language governing permissions and limitations under the License.

package io.reactivex;

import static org.junit.Assert.*;

import org.junit.Test;

import io.reactivex.exceptions.TestException;

public class NotificationTest {

@Test

public void valueOfOnErrorIsNull() {

Notification<Integer> notification = Notification.createOnError(new TestException());

assertNull(notification.getValue());

assertTrue(notification.getError().toString(), notification.getError() instanceof TestException);

}

@Test

public void valueOfOnCompleteIsNull() {

Notification<Integer> notification = Notification.createOnComplete();

assertNull(notification.getValue());

assertNull(notification.getError());

assertTrue(notification.isOnComplete());

}

@Test

public void notEqualsToObject() {

Notification<Integer> n1 = Notification.createOnNext(0);

assertFalse(n1.equals(0));

Notification<Integer> n2 = Notification.createOnError(new TestException());

assertFalse(n2.equals(0));

Notification<Integer> n3 = Notification.createOnComplete();

assertFalse(n3.equals(0));

}

@Test

public void hashCodeIsTheInner() {

Notification<Integer> n1 = Notification.createOnNext(1337);

assertEquals(Integer.valueOf(1337).hashCode(), n1.hashCode());

assertEquals(0, Notification.createOnComplete().hashCode());

}

@Test

public void toStringPattern() {

assertEquals("OnNextNotification[1]", Notification.createOnNext(1).toString());

assertEquals("OnErrorNotification[io.reactivex.exceptions.TestException]", Notification.createOnError(new TestException()).toString());

assertEquals("OnCompleteNotification", Notification.createOnComplete().toString());

}

RxJava/src/test/java/io/reactivex/NotificationTest.java at 2.x · hemanthgit/RxJava · GitHub

Expand file tree

Breadcrumbs

NotificationTest.java

Latest commit

History

Breadcrumbs

NotificationTest.java

File metadata and controls