import akka.dispatch.ExecutionContexts;
import akka.dispatch.Futures;
+import com.google.common.base.Optional;
import com.google.common.io.ByteSource;
import com.google.common.util.concurrent.CheckedFuture;
import com.google.common.util.concurrent.MoreExecutors;
public class RemoteSchemaProviderTest {
- private static final SourceIdentifier ID = new SourceIdentifier("Test", "2015-10-30");
+ private static final SourceIdentifier ID = SourceIdentifier.create("Test", Optional.of("2015-10-30"));
private RemoteSchemaProvider remoteSchemaProvider;
private RemoteYangTextSourceProvider mockedRemoteSchemaRepository;
Mockito.when(mockedRemoteSchemaRepository.getYangTextSchemaSource(ID)).thenReturn(
Futures.<YangTextSchemaSourceSerializationProxy>failed(new SchemaSourceException("Source not provided")));
- CheckedFuture sourceFuture = remoteSchemaProvider.getSource(ID);
+ CheckedFuture<?, ?> sourceFuture = remoteSchemaProvider.getSource(ID);
assertTrue(sourceFuture.isDone());
sourceFuture.checkedGet();
}
-}
\ No newline at end of file
+}