final DataTreeChangeListenerProxy<DOMDataTreeChangeListener> proxy = new DataTreeChangeListenerProxy<>(
actorContext, mockListener, path);
- new Thread() {
- @Override
- public void run() {
- proxy.init("shard-1");
- }
-
- }.start();
+ new Thread(() -> proxy.init("shard-1")).start();
FiniteDuration timeout = duration("5 seconds");
FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class);
final DataTreeChangeListenerProxy<ClusteredDOMDataTreeChangeListener> proxy =
new DataTreeChangeListenerProxy<>(actorContext, mockClusteredListener, path);
- new Thread() {
- @Override
- public void run() {
- proxy.init("shard-1");
- }
-
- }.start();
+ new Thread(() -> proxy.init("shard-1")).start();
FiniteDuration timeout = duration("5 seconds");
FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class);
final DataTreeChangeListenerProxy<DOMDataTreeChangeListener> proxy = new DataTreeChangeListenerProxy<>(
actorContext, mockListener, path);
- new Thread() {
- @Override
- public void run() {
- proxy.init("shard-1");
- }
-
- }.start();
+ new Thread(() -> proxy.init("shard-1")).start();
FiniteDuration timeout = duration("5 seconds");
FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class);
final DataTreeChangeListenerProxy<DOMDataTreeChangeListener> proxy = new DataTreeChangeListenerProxy<>(
actorContext, mockListener, path);
- new Thread() {
- @Override
- public void run() {
- proxy.init("shard-1");
- }
-
- }.start();
+ new Thread(() -> proxy.init("shard-1")).start();
FiniteDuration timeout = duration("5 seconds");
FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class);