I was overthinking it because another application ...

# rx

[andrewg]

I was overthinking it because another application I want to use it for has a dynamic window length...

int windowSeconds = 1;
yourObservable
                .throttleFirst(windowSeconds, TimeUnit.SECONDS)
                .delay(windowSeconds, TimeUnit.SECONDS)

would emit the first item of a window at the end of the window!
Thanks!!!