async def METHOD_NAME(self, *, stream, app):
    channel = Mock(name="channel", send=AsyncMock())
    s2 = stream.echo(channel)
    assert len(s2._processors) == 1
    echoing = s2._processors[0]
    await echoing("val")
    channel.send.assert_called_once_with(value="val")