MarketDataProviderWithOverrideTest.java 文件源码

public void testSubscriptionSuccess() throws InterruptedException {
  final MarketDataInjectorImpl overrideInjector = new MarketDataInjectorImpl();
  final MockMarketDataProvider p1 = new MockMarketDataProvider("p1", true, 1);
  final MarketDataProviderWithOverride provider = new MarketDataProviderWithOverride(p1, overrideInjector);
  final MarketDataListener listener = mock(MarketDataListener.class);
  provider.addListener(listener);

  final ValueSpecification spec = getSpecification(1);

  provider.subscribe(spec);
  p1.awaitSubscriptionResponses();

  verify(listener).subscriptionsSucceeded(Collections.singleton(spec));
  verify(listener, VerificationModeFactory.noMoreInteractions()).subscriptionsSucceeded(Collections.singleton(Mockito.<ValueSpecification>anyObject()));

  p1.valuesChanged(Collections.singleton(spec));
  verify(listener, VerificationModeFactory.times(1)).valuesChanged(Collections.singleton(spec));
}