- added StreamExtensions.latest, which updates an atomic ref with the
latest value going through the stream
updated test