docs: def filter(self, predicate) -> 'Observable':
          """Filter the on_next continuation functions"""
          source = self
  
          def subscribe(on_next):
              def _next(x):
                  if predicate(x):
                      on_next(x)
  
              return source.subscribe(_next)
          return Observable(subscribe)