We are utilizing some internal rxjava classes for our custom operator and functions. We should remove this to prevent these from not being visible in the future. We may also be able to make operators that are a bit cleaner as well.