Всем привет. изучаю akka streams и в качестве практики

Question

Всем привет. изучаю akka streams и в качестве практики

решил прикрутить akka streams к vk streaming api.
По логике все достаточно логично vk отдает по вебсокету то что постят юзеры и это как раз и будет нашим source'ом, а дальше уже строй поток обработки как хочется.
У меня возникли проблемы как раз на этом моменте. как из vk streaming api сделать akka stream Source.
Если в кратце для vk streaming api есть пример на джаве(он отлично у меня запустился, данные идут)
https://github.com/VKCOM/vk-java-sdk#12-streaming-api

И собственно в примере предлагается собирать данные вот так

streamingClient.stream().get(streamingActortor, new StreamingEventHandler() {
@Override
public void handle(StreamingCallbackMessage message) {
System.out.println(message.getEvent().getText());
}
}).execute();

подскажите как это в Source переделать?
P.S. понимаю что java и много кода но всеже буду благодарен если кто то хотя бы направление куда думать подскажет