本文整理汇总了Java中rx.observers.TestObserver类的典型用法代码示例。如果您正苦于以下问题:Java TestObserver类的具体用法?Java TestObserver怎么用?Java TestObserver使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
TestObserver类属于rx.observers包,在下文中一共展示了TestObserver类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testPagingCapabilities
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testPagingCapabilities() {
PublishSubject<Object> view = PublishSubject.create();
BehaviorSubject<Integer> nextPageRequests = BehaviorSubject.create();
final TestObserver<Delivery<Object, String>> testObserver = new TestObserver<>();
nextPageRequests
.concatMap(new Func1<Integer, Observable<Integer>>() {
@Override
public Observable<Integer> call(Integer targetPage) {
return targetPage <= requestedPageCount ?
Observable.<Integer>never() :
Observable.range(requestedPageCount, targetPage - requestedPageCount);
}
})
.doOnNext(new Action1<Integer>() {
@Override
public void call(Integer it) {
requestedPageCount = it + 1;
}
})
.startWith(Observable.range(0, requestedPageCount))
.concatMap(new Func1<Integer, Observable<String>>() {
@Override
public Observable<String> call(final Integer page) {
return requestPage(page, PAGE_SIZE);
}
})
.compose(new DeliverReplay<Object, String>(view))
.subscribe(testObserver);
ArrayList<Delivery<Object, String>> onNext = new ArrayList<>();
testObserver.assertReceivedOnNext(onNext);
view.onNext(999);
addOnNext(onNext, 999, 0, 1, 2);
testObserver.assertReceivedOnNext(onNext);
nextPageRequests.onNext(2);
addOnNext(onNext, 999, 3, 4, 5);
testObserver.assertReceivedOnNext(onNext);
view.onNext(null);
assertEquals(0, testObserver.getOnCompletedEvents().size());
testObserver.assertReceivedOnNext(onNext);
nextPageRequests.onNext(3);
assertEquals(0, testObserver.getOnCompletedEvents().size());
testObserver.assertReceivedOnNext(onNext);
view.onNext(9999);
addOnNext(onNext, 9999, 0, 1, 2, 3, 4, 5, 6, 7, 8);
assertEquals(0, testObserver.getOnCompletedEvents().size());
testObserver.assertReceivedOnNext(onNext);
}
开发者ID:weiwenqiang,项目名称:GitHub,代码行数:62,代码来源:DeliverReplayTest.java
示例2: testStickyBroadcast
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testStickyBroadcast()
{
String action = "TEST_STICKY_ACTION";
IntentFilter intentFilter = new IntentFilter(action);
Application application = Robolectric.application;
Intent intent = new Intent(action);
application.sendStickyBroadcast(intent);
Observable<Intent> observable = ContentObservable.fromBroadcast(application, intentFilter);
final Observer<Intent> observer = mock(Observer.class);
final Subscription subscription = observable.subscribe(new TestObserver<>(observer));
final InOrder inOrder = inOrder(observer);
inOrder.verify(observer, times(1)).onNext(intent);
application.sendBroadcast(intent);
inOrder.verify(observer, times(1)).onNext(intent);
subscription.unsubscribe();
application.sendBroadcast(intent);
inOrder.verify(observer, never()).onNext(any(Intent.class));
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verify(observer, never()).onCompleted();
}
开发者ID:andrefio,项目名称:Rx.ContentObservable,代码行数:27,代码来源:OperatorBroadcastRegisterTest.java
示例3: testSharedPreferences
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testSharedPreferences()
{
Application application = Robolectric.application;
SharedPreferences sharedPreferences = PreferenceManager.getDefaultSharedPreferences(application);
Observable<String> observable = ContentObservable.fromSharedPreferencesChanges(sharedPreferences);
final Observer<String> observer = mock(Observer.class);
final Subscription subscription = observable.subscribe(new TestObserver<>(observer));
final InOrder inOrder = inOrder(observer);
inOrder.verify(observer, never()).onNext(any(String.class));
sharedPreferences.edit().putBoolean("a", true).commit();
inOrder.verify(observer, times(1)).onNext("a");
sharedPreferences.edit().putInt("b", 9).commit();
inOrder.verify(observer, times(1)).onNext("b");
subscription.unsubscribe();
sharedPreferences.edit().putInt("c", 42).commit();
inOrder.verify(observer, never()).onNext(any(String.class));
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verify(observer, never()).onCompleted();
}
开发者ID:andrefio,项目名称:Rx.ContentObservable,代码行数:27,代码来源:OperatorSharedPreferencesChangeTest.java
示例4: testSuccess
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testSuccess() throws Exception {
@SuppressWarnings("unchecked")
Future<Object> future = mock(Future.class);
Object value = new Object();
when(future.get()).thenReturn(value);
@SuppressWarnings("unchecked")
Observer<Object> o = mock(Observer.class);
Subscription sub = Observable.from(future).subscribe(new TestObserver<Object>(o));
sub.unsubscribe();
verify(o, times(1)).onNext(value);
verify(o, times(1)).onComplete();
verify(o, never()).onError(any(Throwable.class));
verify(future, times(1)).cancel(true);
}
开发者ID:akarnokd,项目名称:RxJavaFlow,代码行数:18,代码来源:OnSubscribeToObservableFutureTest.java
示例5: testFailure
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testFailure() throws Exception {
@SuppressWarnings("unchecked")
Future<Object> future = mock(Future.class);
RuntimeException e = new RuntimeException();
when(future.get()).thenThrow(e);
@SuppressWarnings("unchecked")
Observer<Object> o = mock(Observer.class);
Subscription sub = Observable.from(future).subscribe(new TestObserver<Object>(o));
sub.unsubscribe();
verify(o, never()).onNext(null);
verify(o, never()).onComplete();
verify(o, times(1)).onError(e);
verify(future, times(1)).cancel(true);
}
开发者ID:akarnokd,项目名称:RxJavaFlow,代码行数:18,代码来源:OnSubscribeToObservableFutureTest.java
示例6: testCheckObservable_Incorrectly_Passes
import rx.observers.TestObserver; //导入依赖的package包/类
/**
* Demonstrates that the indirection of the internal PublishSubject within
* the Network's Layer class is what causes failed assertions to not be
* recognized by JUnit (i.e. they get swallowed).
*
* This test passes even though there are errors.
*/
@Test
public void testCheckObservable_Incorrectly_Passes() {
FauxNetwork network = new FauxNetwork();
TestObserver<Inference> observer = new TestObserver<Inference>() {
@Override
public void onNext(Inference i) {
assertTrue(i.getAnomalyScore() == 0.0);
}
};
network.subscribe(observer);
ManualInput inf = new ManualInput();
inf.anomalyScore(1.0);
network.compute(inf);
// Test that there are errors even though the test passes.
assertTrue(hasErrors(observer));
}
开发者ID:numenta,项目名称:htm.java,代码行数:29,代码来源:ObservableTestBaseTest.java
示例7: testLines
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testLines() throws IOException {
Path testFile = tempFile("target/testing/lines-test");
List<String> lines = createTestFile(testFile,
"line1",
"line2",
"line3",
"",
"line5"
);
TestObserver<String> testObserver = new TestObserver<>();
Observable<String> contents = FileObservable.lines(testFile);
contents.subscribe(testObserver);
testObserver.assertReceivedOnNext(lines);
testObserver.assertTerminalEvent();
}
开发者ID:OpenNMS,项目名称:newts,代码行数:23,代码来源:FileObservableTest.java
示例8: TestSingleSubscriber
import rx.observers.TestObserver; //导入依赖的package包/类
/**
* Constructs a TestSingleSubscriber with a delegate Observer to wrap.
*
* @param delegate the Observer instance to wrap
* @throws NullPointerException if delegate is null
*/
public TestSingleSubscriber(Observer<T> delegate) {
if (delegate == null) {
throw new NullPointerException();
}
this.testObserver = new TestObserver<T>(delegate);
}
开发者ID:Alezhka,项目名称:JWaves,代码行数:13,代码来源:TestSingleSubscriber.java
示例9: testBroadcast
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testBroadcast()
{
String action = "TEST_ACTION";
IntentFilter intentFilter = new IntentFilter(action);
Application application = Robolectric.application;
Observable<Intent> observable = ContentObservable.fromBroadcast(application, intentFilter);
final Observer<Intent> observer = mock(Observer.class);
final Subscription subscription = observable.subscribe(new TestObserver<>(observer));
final InOrder inOrder = inOrder(observer);
inOrder.verify(observer, never()).onNext(any(Intent.class));
Intent intent = new Intent(action);
application.sendBroadcast(intent);
inOrder.verify(observer, times(1)).onNext(intent);
application.sendBroadcast(intent);
inOrder.verify(observer, times(1)).onNext(intent);
subscription.unsubscribe();
application.sendBroadcast(intent);
inOrder.verify(observer, never()).onNext(any(Intent.class));
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verify(observer, never()).onCompleted();
}
开发者ID:andrefio,项目名称:Rx.ContentObservable,代码行数:29,代码来源:OperatorBroadcastRegisterTest.java
示例10: testPermissionBroadcast
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testPermissionBroadcast()
{
String action = "TEST_ACTION";
String permission = "test_permission";
IntentFilter intentFilter = new IntentFilter(action);
Application application = Robolectric.application;
Observable<Intent> observable = ContentObservable.fromBroadcast(application, intentFilter, permission, null);
final Observer<Intent> observer = mock(Observer.class);
final Subscription subscription = observable.subscribe(new TestObserver<>(observer));
final InOrder inOrder = inOrder(observer);
inOrder.verify(observer, never()).onNext(any(Intent.class));
Intent intent = new Intent(action);
application.sendBroadcast(intent);
inOrder.verify(observer, never()).onNext(intent);
application.sendBroadcast(intent, permission);
inOrder.verify(observer, times(1)).onNext(intent);
subscription.unsubscribe();
application.sendBroadcast(intent);
application.sendBroadcast(intent, permission);
inOrder.verify(observer, never()).onNext(any(Intent.class));
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verify(observer, never()).onCompleted();
}
开发者ID:andrefio,项目名称:Rx.ContentObservable,代码行数:31,代码来源:OperatorBroadcastRegisterTest.java
示例11: testLocalBroadcast
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testLocalBroadcast()
{
String action = "TEST_ACTION";
IntentFilter intentFilter = new IntentFilter(action);
Application application = Robolectric.application;
Observable<Intent> observable = ContentObservable.fromLocalBroadcast(application, intentFilter);
final Observer<Intent> observer = mock(Observer.class);
final Subscription subscription = observable.subscribe(new TestObserver<>(observer));
final InOrder inOrder = inOrder(observer);
inOrder.verify(observer, never()).onNext(any(Intent.class));
Intent intent = new Intent(action);
LocalBroadcastManager localBroadcastManager = LocalBroadcastManager.getInstance(application);
localBroadcastManager.sendBroadcast(intent);
inOrder.verify(observer, times(1)).onNext(intent);
localBroadcastManager.sendBroadcast(intent);
inOrder.verify(observer, times(1)).onNext(intent);
subscription.unsubscribe();
localBroadcastManager.sendBroadcast(intent);
inOrder.verify(observer, never()).onNext(any(Intent.class));
inOrder.verify(observer, never()).onError(any(Throwable.class));
inOrder.verify(observer, never()).onCompleted();
}
开发者ID:andrefio,项目名称:Rx.ContentObservable,代码行数:30,代码来源:OperatorLocalBroadcastRegisterTest.java
示例12: bindFragmentToSourceFromDifferentThread
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void bindFragmentToSourceFromDifferentThread() throws InterruptedException {
CountDownLatch done = new CountDownLatch(1);
AppObservable.bindFragment(fragment, TestUtil.atBackgroundThread(done)).subscribe(new TestObserver<String>(observer));
done.await();
ShadowLooper.runUiThreadTasksIncludingDelayedTasks();
verify(observer).onNext(TestUtil.STRING_EXPECTATION);
verify(observer).onCompleted();
}
开发者ID:pine,项目名称:RxBindroid,代码行数:12,代码来源:AppObservableTest.java
示例13: bindSupportFragmentToSourceFromDifferentThread
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void bindSupportFragmentToSourceFromDifferentThread() throws InterruptedException {
CountDownLatch done = new CountDownLatch(1);
AppObservable.bindSupportFragment(supportFragment, TestUtil.atBackgroundThread(done)).subscribe(new TestObserver<String>(observer));
done.await();
ShadowLooper.runUiThreadTasksIncludingDelayedTasks();
verify(observer).onNext(TestUtil.STRING_EXPECTATION);
verify(observer).onCompleted();
}
开发者ID:pine,项目名称:RxBindroid,代码行数:12,代码来源:AppObservableTest.java
示例14: bindActivityToSourceFromDifferentThread
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void bindActivityToSourceFromDifferentThread() throws InterruptedException {
CountDownLatch done = new CountDownLatch(1);
AppObservable.bindActivity(activity, TestUtil.atBackgroundThread(done)).subscribe(new TestObserver<String>(observer));
done.await();
ShadowLooper.runUiThreadTasksIncludingDelayedTasks();
verify(observer).onNext(TestUtil.STRING_EXPECTATION);
verify(observer).onCompleted();
}
开发者ID:pine,项目名称:RxBindroid,代码行数:12,代码来源:AppObservableTest.java
示例15: rejectEvens
import rx.observers.TestObserver; //导入依赖的package包/类
@Test public void rejectEvens() {
final Observer<Integer> observer = mock(Observer.class);
Observable.just(1, 2, 3, 4, 5) //
.lift(reject(n -> n % 2 == 0)) //
.subscribe(new TestObserver<>(observer));
InOrder inOrder = inOrder(observer);
inOrder.verify(observer, times(1)).onNext(1);
inOrder.verify(observer, times(1)).onNext(3);
inOrder.verify(observer, times(1)).onNext(5);
}
开发者ID:f2prateek,项目名称:rxjava-reject,代码行数:13,代码来源:RejectTest.java
示例16: testSimpleBelowCapacity
import rx.observers.TestObserver; //导入依赖的package包/类
@Test(timeout = 1000)
public void testSimpleBelowCapacity() {
Observable<Integer> source = Observable.just(1).onBackpressureBlock(10);
TestObserver<Integer> o = new TestObserver<Integer>();
source.subscribe(o);
o.assertValues((1));
o.assertTerminalEvent();
assertTrue(o.getOnErrorEvents().isEmpty());
}
开发者ID:akarnokd,项目名称:RxJavaFlow,代码行数:12,代码来源:OnBackpressureBlockTest.java
示例17: checkObserver
import rx.observers.TestObserver; //导入依赖的package包/类
protected <T> void checkObserver(TestObserver<T> obs) {
if(obs.getOnErrorEvents().size() > 0) {
Throwable e = (Throwable) obs.getOnErrorEvents().get(0);
e.printStackTrace();
throw new RuntimeException(e);
}
}
开发者ID:numenta,项目名称:htm.java,代码行数:8,代码来源:ObservableTestBase.java
示例18: testBasicSetupEncoder_UsingSubscribe
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testBasicSetupEncoder_UsingSubscribe() {
Parameters p = NetworkTestHarness.getParameters().copy();
p = p.union(NetworkTestHarness.getDayDemoTestEncoderParams());
p.set(KEY.RANDOM, new MersenneTwister(42));
MultiEncoder me = MultiEncoder.builder().name("").build();
Layer<Map<String, Object>> l = new Layer<>(p, me, null, null, null, null);
final int[][] expected = new int[7][8];
expected[0] = new int[] { 1, 1, 0, 0, 0, 0, 0, 1 };
expected[1] = new int[] { 1, 1, 1, 0, 0, 0, 0, 0 };
expected[2] = new int[] { 0, 1, 1, 1, 0, 0, 0, 0 };
expected[3] = new int[] { 0, 0, 1, 1, 1, 0, 0, 0 };
expected[4] = new int[] { 0, 0, 0, 1, 1, 1, 0, 0 };
expected[5] = new int[] { 0, 0, 0, 0, 1, 1, 1, 0 };
expected[6] = new int[] { 0, 0, 0, 0, 0, 1, 1, 1 };
TestObserver<Inference> tester;
l.subscribe(tester = new TestObserver<Inference>() {
int seq = 0;
@Override public void onCompleted() {}
@Override public void onNext(Inference output) {
assertTrue(Arrays.equals(expected[seq++], output.getSDR()));
}
});
Map<String, Object> inputs = new HashMap<String, Object>();
for(double i = 0;i < 7;i++) {
inputs.put("dayOfWeek", i);
l.compute(inputs);
}
// Check for exception during the TestObserver's onNext() execution.
checkObserver(tester);
}
开发者ID:numenta,项目名称:htm.java,代码行数:37,代码来源:LayerTest.java
示例19: testBasicSetupEncoder_UsingObserve
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testBasicSetupEncoder_UsingObserve() {
Parameters p = NetworkTestHarness.getParameters().copy();
p = p.union(NetworkTestHarness.getDayDemoTestEncoderParams());
p.set(KEY.RANDOM, new MersenneTwister(42));
MultiEncoder me = MultiEncoder.builder().name("").build();
Layer<Map<String, Object>> l = new Layer<>(p, me, null, null, null, null);
final int[][] expected = new int[7][8];
expected[0] = new int[] { 1, 1, 0, 0, 0, 0, 0, 1 };
expected[1] = new int[] { 1, 1, 1, 0, 0, 0, 0, 0 };
expected[2] = new int[] { 0, 1, 1, 1, 0, 0, 0, 0 };
expected[3] = new int[] { 0, 0, 1, 1, 1, 0, 0, 0 };
expected[4] = new int[] { 0, 0, 0, 1, 1, 1, 0, 0 };
expected[5] = new int[] { 0, 0, 0, 0, 1, 1, 1, 0 };
expected[6] = new int[] { 0, 0, 0, 0, 0, 1, 1, 1 };
Observable<Inference> o = l.observe();
TestObserver<Inference> tester;
o.subscribe(tester = new TestObserver<Inference>() {
int seq = 0;
@Override public void onCompleted() {}
@Override public void onNext(Inference output) {
assertTrue(Arrays.equals(expected[seq++], output.getSDR()));
}
});
Map<String, Object> inputs = new HashMap<String, Object>();
for(double i = 0;i < 7;i++) {
inputs.put("dayOfWeek", i);
l.compute(inputs);
}
// Check for exception during the TestObserver's onNext() execution.
checkObserver(tester);
}
开发者ID:numenta,项目名称:htm.java,代码行数:38,代码来源:LayerTest.java
示例20: testBasicSetup_SPandTM
import rx.observers.TestObserver; //导入依赖的package包/类
@Test
public void testBasicSetup_SPandTM() {
Parameters p = NetworkTestHarness.getParameters().copy();
p.set(KEY.RANDOM, new MersenneTwister(42));
int[][] inputs = new int[7][8];
inputs[0] = new int[] { 1, 1, 0, 0, 0, 0, 0, 1 };
inputs[1] = new int[] { 1, 1, 1, 0, 0, 0, 0, 0 };
inputs[2] = new int[] { 0, 1, 1, 1, 0, 0, 0, 0 };
inputs[3] = new int[] { 0, 0, 1, 1, 1, 0, 0, 0 };
inputs[4] = new int[] { 0, 0, 0, 1, 1, 1, 0, 0 };
inputs[5] = new int[] { 0, 0, 0, 0, 1, 1, 1, 0 };
inputs[6] = new int[] { 0, 0, 0, 0, 0, 1, 1, 1 };
Layer<int[]> l = new Layer<>(p, null, new SpatialPooler(), new TemporalMemory(), null, null);
TestObserver<Inference> tester;
l.subscribe(tester = new TestObserver<Inference>() {
@Override public void onCompleted() {}
@Override
public void onNext(Inference i) {
assertNotNull(i);
assertTrue(i.getSDR().length > 0);
}
});
// Now push some fake data through so that "onNext" is called above
l.compute(inputs[0]);
l.compute(inputs[1]);
// Check for exception during the TestObserver's onNext() execution.
checkObserver(tester);
}
开发者ID:numenta,项目名称:htm.java,代码行数:33,代码来源:LayerTest.java
注:本文中的rx.observers.TestObserver类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论