Rename JdbcIntegrationTest to JdbcLiveTest (#2600)
This commit is contained in:
parent
3e192a0707
commit
f95f0da640
@ -21,9 +21,9 @@ import org.junit.After;
|
|||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
public class JdbcIntegrationTest {
|
public class JdbcLiveTest {
|
||||||
|
|
||||||
private static final Logger LOG = Logger.getLogger(JdbcIntegrationTest.class);
|
private static final Logger LOG = Logger.getLogger(JdbcLiveTest.class);
|
||||||
|
|
||||||
private Connection con;
|
private Connection con;
|
||||||
|
|
@ -13,8 +13,9 @@ public class ResourceManagement {
|
|||||||
return resource;
|
return resource;
|
||||||
},
|
},
|
||||||
r -> Observable.create(o -> {
|
r -> Observable.create(o -> {
|
||||||
for (Character c : r.toCharArray())
|
for (Character c : r.toCharArray()) {
|
||||||
o.onNext(c);
|
o.onNext(c);
|
||||||
|
}
|
||||||
o.onCompleted();
|
o.onCompleted();
|
||||||
}),
|
}),
|
||||||
r -> System.out.println("Disposed: " + r)
|
r -> System.out.println("Disposed: " + r)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user