stream-join modified for new api