Я использую драйвер реактивного потока mongodb для java в инфраструктуре воспроизведения, я успешно делаю запрос на печать документа с помощью PrintDocumentSubscribe, subscriber -publisher, но мне нужен документ в ответ, но я не могу сделать это как тип возвратаonNext () onCompleted () является недействительным
public static class PrintSubscriber<T> extends OperationSubscriber<T> {
private final String message;
/**
* A Subscriber that outputs a message onComplete.
*
* @param message the message to output onComplete
*/
public PrintSubscriber(final String message) {
this.message = message;
}
@Override
public void onComplete() {
System.out.println(format(message, getReceived()));
super.onComplete();
}
}
он печатает результат, но я хочу сохранить его в переменной для дальнейшего использования