Как мне использовать Source.asSubscriber, чтобы обернуть реактивный слушатель?Я не понимаю его...

Мне нужно выполнить некоторый код, когда Observable будет завершен в зависимости от того,...

Я пытаюсь написать очень простой вводный пример использования Akka Streams. Я пытаюсь в основном...