async def METHOD_NAME(redis_stream_backend: RedisChannelsStreamBackend) -> None:
    await redis_stream_backend.publish(b"something", ["foo", "bar", "baz"])
    result = await redis_stream_backend.flush_all()
    assert result == 3