@Override
public void initialize(Bootstrap<RxJerseyConfiguration> bootstrap) {
    bootstrap.addBundle(new RxJerseyBundle<RxJerseyConfiguration>()
            .setClientConfigurationProvider(config -> config.client)
            .register(HeaderInterceptor.class)
    );
}

public void run(RxJerseyConfiguration configuration, Environment environment) throws Exception {
    JerseyEnvironment jersey = environment.jersey();

    Client client = new JerseyClientBuilder(environment)
            .using(configuration.client)
            .using(new GrizzlyConnectorProvider())
            .buildRx("Client", RxObservableInvoker.class);

    RxJerseyServerFeature rxJerseyServerFeature = new RxJerseyServerFeature()
            .register(HeaderInterceptor.class);

    RxJerseyClientFeature rxJerseyClientFeature = new RxJerseyClientFeature()
            .register(client);

    jersey.register(rxJerseyServerFeature);
    jersey.register(rxJerseyClientFeature);
}