@Override
    public Flowable<SyncingNotfication> syncingStatusNotifications() {
        return web3jService.subscribe(
                new Request<>(
                        "eth_subscribe",
                        Arrays.asList("syncing"),
                        web3jService,
                        EthSubscribe.class),
                "eth_unsubscribe",
                SyncingNotfication.class);
    }
@Test
    public void testSyncingStatusNotifications() {
        geth.syncingStatusNotifications();

        verify(webSocketClient)
                .send(
                        matches(
                                "\\{\"jsonrpc\":\"2.0\",\"method\":\"eth_subscribe\","
                                        + "\"params\":\\[\"syncing\"],\"id\":[0-9]{1,}}"));
    }