@Test
public void getExistingYangTextSchemaSource() throws IOException, InterruptedException, ExecutionException {

    YangTextSchemaSource schemaSource = YangTextSchemaSource.delegateForByteSource(ID,
        CharSource.wrap("Test").asByteSource(StandardCharsets.UTF_8));
    doReturn(Futures.successful(new YangTextSchemaSourceSerializationProxy(schemaSource)))
        .when(mockedRemoteSchemaRepository).getYangTextSchemaSource(ID);
    YangTextSchemaSource providedSource = remoteSchemaProvider.getSource(ID).get();
    assertEquals(ID, providedSource.getIdentifier());
    assertArrayEquals(schemaSource.read(), providedSource.read());
}