Как создать свой интерфейс для RX?

Observable.create(subThread -> vkRequest.executeSyncWithListener(new VKRequest.VKRequestListener() {
        @Override
        public void onComplete(VKResponse response) {
            subThread.onNext(response);
            subThread.onComplete();
        }
        @Override
        public void attemptFailed(VKRequest request, int attemptNumber, int totalAttempts) {
            subThread.onError(new Exception());
        }
        @Override
        public void onError(VKError error) {
            subThread.onError(error.httpError);
        }
    })

Как создать интерфейс и добавить туда весь код который находиться в методе create?

А затем новый интерфейс использовать в create? Как правильно это сделать?

Так как я данный кусок кода буду использовать в более чем 30 классах, Чтобы потом проблем не было я вот решил использовать 1 интерфейс.